808 references to RunContinuationsAsynchronously
HttpStress (1)
Program.cs (1)
673var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
IIS.Tests (2)
StrictTestServerTests.cs (1)
28return new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Utilities\TestServer.cs (1)
43private readonly TaskCompletionSource _startedTaskCompletionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InMemory.FunctionalTests (221)
ChunkedRequestTests.cs (2)
856var readStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 858var exTcs = new TaskCompletionSource<BadHttpRequestException>(TaskCreationOptions.RunContinuationsAsynchronously);
ChunkedResponseTests.cs (1)
489var flushWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionLimitTests.cs (6)
29var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 30var releasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 31var lockedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 109var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 161var openedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 162var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionMiddlewareTests.cs (1)
200var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2ConnectionTests.cs (30)
1139var stream1Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1140var stream1ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1141var stream3Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1142var stream3ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1684var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1737var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1930var connectionAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1931var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2214var firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2215var finishFirstRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2216var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2217var finishSecondRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2419var requestBlocker = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3034var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3035var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3152var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3153var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3337var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3361var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3385var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3408var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4002var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4003var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4104var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4105var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4332var backpressureObservedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4333var backpressureReleasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4845var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5233var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5310var tcs = new TaskCompletionSource<byte[]>(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2KeepAliveTests.cs (2)
262var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 315var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2StreamTests.cs (45)
1589var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3188var appFinished = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 3247var writeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3713var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4156var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4157var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4158var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4209var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4210var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4211var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4276var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4277var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4330var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4331var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4332var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4396var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4397var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4398var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4452var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4453var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4454var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4566var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4567var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4568var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4645var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4646var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4647var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4719var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4720var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4721var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4789var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4790var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4791var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4860var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4861var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4862var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4940var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4941var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4942var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5024var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5025var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5026var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5106var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5107var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5108var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TestBase.cs (7)
134protected readonly TaskCompletionSource _closingStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 135protected readonly TaskCompletionSource _closedStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 589var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 604var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 623var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 665var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 710var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TimeoutTests.cs (3)
73var setTimeoutTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 310private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 891var backpressureTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3ConnectionTests.cs (1)
40var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3StreamTests.cs (48)
714var headersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 756var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1130var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1131var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1132var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1177var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1178var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1179var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1230var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1231var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1277var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1278var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1279var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1330var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1331var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1332var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1379var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1380var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1381var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1472var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1473var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1474var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1532var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1533var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1534var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1587var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1588var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1589var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1644var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1645var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1646var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1702var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1703var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1704var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1761var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1762var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1763var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1825var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1826var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1827var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1888var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1889var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1890var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2015var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2040var readTrailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2797var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2798var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2799var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3TimeoutTests.cs (2)
391}, null, true, new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 417private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportHandshakeTests.cs (1)
24var appCompletedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportSessionTests.cs (3)
17var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 38var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 73var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportTestUtilities.cs (1)
27var appCompletedTcs = new TaskCompletionSource<IWebTransportSession>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpsTests.cs (2)
274var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 822public TaskCompletionSource LogTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KeepAliveTimeoutTests.cs (2)
20private readonly TaskCompletionSource _firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 280var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestBodyTimeoutTests.cs (4)
23var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 102var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 143var appRunningTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 144var exceptionSwallowedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (11)
111var helloTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 112var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 230var pathTcs = new TaskCompletionSource<PathString>(TaskCreationOptions.RunContinuationsAsynchronously); 231var rawTargetTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 232var queryTcs = new TaskCompletionSource<IQueryCollection>(TaskCreationOptions.RunContinuationsAsynchronously); 1156var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1157var tcs2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1622var appEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1623var delayEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1894var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1991var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseDrainingTests.cs (1)
38var outputBufferedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (27)
38TaskCompletionSource onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 146var writeBlockedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 210var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 399var delayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 436var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 666var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 702var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 742var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 781var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 823var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 892var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1085var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1139var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1196var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1416var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1447var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1480var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1515var responseWritten = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2507var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2552var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2809var closeTaskTcs = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 3098var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3279var onStartingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3330var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3832var middlewareCompletionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4542var disposedTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
420stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 475internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1158_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159_disposingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TestTransport\InMemoryTransportConnection.cs (2)
22private readonly TaskCompletionSource _waitForCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 118private readonly TaskCompletionSource _tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
UpgradeTests.cs (7)
25var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 68var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 120var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 270var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 304var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 354var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 391var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Interop.FunctionalTests (58)
H2SpecCommands.cs (1)
242var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2RequestTests.cs (1)
30var protocolTcs = new TaskCompletionSource<SslProtocols>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3RequestTests.cs (24)
34private readonly TaskCompletionSource _completeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 35private readonly TaskCompletionSource<Stream> _getStreamTcs = new TaskCompletionSource<Stream>(TaskCreationOptions.RunContinuationsAsynchronously); 234var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 454var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 455var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 536var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 654var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 655var writeAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 965var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 966var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1068var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1157var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1549var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1550var connectionStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1614var connectionStartedTcs1 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1616var connectionStartedTcs2 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1618var connectionStartedTcs3 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1719var connectionStartedTcs = new TaskCompletionSource<MultiplexedConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1858var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1859var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1860var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1970var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1971var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpClientHttp2InteropTests.cs (30)
106var allRequestsReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 154var allRequestsReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 320var lastPacket = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 402var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 453private readonly TaskCompletionSource _sendStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480_sendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 548var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 608var receivedHeaders = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 697var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 698var serverReset = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 699var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 754var serverReset = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 755var responseHeadersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 812var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 813var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 858var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 859var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 903var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 904var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 945var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 985var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1027var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1079var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1131var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1192var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1253var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1414var requestFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1456var responseFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1492var requestFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InteropTests (3)
Helpers\ClientProcess.cs (1)
38_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Helpers\WebsiteProcess.cs (1)
43_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components (2)
Routing\Router.cs (2)
285var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 296var cancellationTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\CircuitHostTest.cs (1)
784_renderTcsArray[i] = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Tests (5)
RendererTest.cs (5)
2385var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2430var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2469var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2505var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4296var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.FunctionalTests (1)
WebApplicationFunctionalTests.cs (1)
139var configChangedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Grpc.JsonTranscoding.IntegrationTests (5)
Infrastructure\SyncPoint.cs (1)
13var taskCreationOptions = runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None;
ServerStreamingTests.cs (2)
49var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 86var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
UnaryTests.cs (2)
52var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 90var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (2)
Infrastructure\SyncPoint.cs (1)
13var taskCreationOptions = runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None;
UnaryServerCallHandlerTests.cs (1)
1247var tcs = new TaskCompletionSource<float?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Hosting.FunctionalTests (3)
ShutdownTests.cs (2)
68var startedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 69var completedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WebHostBuilderTests.cs (1)
39var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Hosting.Tests (2)
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Connections (2)
Internal\HttpConnectionContext.cs (1)
60private readonly TaskCompletionSource _disposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\HttpConnectionDispatcher.cs (1)
209var currentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Connections.Tests (11)
HttpConnectionDispatcherTests.cs (6)
1566var lastPollTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2409var calledOnReconnectedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2940var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2944tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3149var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4009_pause = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionManagerTests.cs (3)
290var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 313var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 340var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Tests (8)
HttpContextAccessorTests.cs (8)
38var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 39var waitForNullTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 40var afterNullCheckTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 83var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var waitForNullTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 85var afterNullCheckTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 129var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.HttpLogging.Tests (1)
TestW3CLoggerProcessor.cs (1)
52_tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation (1)
RuntimeViewCompiler.cs (1)
144taskSource = new TaskCompletionSource<CompiledViewDescriptor>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.TagHelpers (2)
Cache\DistributedCacheTagHelperService.cs (1)
77var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
CacheTagHelper.cs (1)
97var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.TagHelpers.Test (12)
CacheTagHelperTest.cs (6)
543var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 544var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 545var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 628var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 629var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
DistributedCacheTagHelperTest.cs (6)
536var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 538var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 631var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Testing (1)
DeferredHostBuilder.cs (1)
22private readonly TaskCompletionSource _hostStartTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching (2)
DispatcherExtensions.cs (2)
24var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously); 63var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching.Tests (4)
OutputCacheMiddlewareTests.cs (4)
858var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 859var blocker2 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 920var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 921var blocker2 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.RateLimiting.Tests (2)
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.ResponseCompression.Tests (20)
ResponseCompressionMiddlewareTest.cs (20)
622var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 668var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 713var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 772var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 827new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 828new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 829new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 830new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 831new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 897new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 898new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 899new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 900new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 901new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 961new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 962new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 963new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 964new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 965new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1176var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Routing (1)
EndpointRoutingMiddleware.cs (1)
253var initialization = new TaskCompletionSource<Matcher>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys (2)
MessagePump.cs (1)
25private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (86)
AuthenticationTests.cs (1)
170var completed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2Tests.cs (7)
656var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 698var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 745var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 795var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 847var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 893var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 942var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3Tests.cs (2)
185var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 218var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Listener\ResponseBodyTests.cs (8)
243var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 279var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 315var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 342var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 372var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 412var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 451var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 485var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Listener\ServerTests.cs (3)
25var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 54var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
OpaqueUpgradeTests.cs (4)
109var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 131var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 164var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 309var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (4)
478var registered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var result = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 527var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 528var result = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseBodyTests.cs (5)
19var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 45var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 72var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 283var requestThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseSendFileTests.cs (21)
38var appThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 370var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 398var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 426var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 453var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 533var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 534var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 576var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 577var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 579var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 633var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 634var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 635var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (8)
130var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 131var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 161var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 162var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 191var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 220var readStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 221var readCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTrailersTests.cs (3)
121var responseFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 227var trailersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 248var trailersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ServerTests.cs (20)
148var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 168var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 169var stopped = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 189var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var shutdown = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 278var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 279var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 280var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 312var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 313var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 418var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 419var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 452var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 453var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 489var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 490var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 526var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 527var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 563var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 564var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpServer.cs (1)
33private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IISIntegration.Tests (8)
IISMiddlewareTests.cs (8)
105var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 106var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 164var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 165var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 209var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 210var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 254var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 255var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IntegrationTesting (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Internal\ConnectionDispatcher.cs (1)
15private readonly TaskCompletionSource _acceptLoopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\KestrelConnection.cs (1)
19private readonly TaskCompletionSource _completionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (2)
134_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 168_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\TransportConnectionManager.cs (1)
96var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\KestrelServerImpl.cs (1)
32private readonly TaskCompletionSource _stoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (25)
CertificatePathWatcherTests.cs (4)
133var signalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var signalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 366var changeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 370var logNoLastModifiedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConcurrentPipeWriterTests.cs (13)
24new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 25new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 87new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 88new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 89new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 125mockPipeWriter.FlushTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145mockPipeWriter.FlushTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 185new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 186new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 269new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 270new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 337new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 338new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously),
HeartbeatTests.cs (2)
109var handlerStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 152var handlerStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.cs (1)
32var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KestrelServerTests.cs (2)
664var unbindTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 772changeCallbackRegisteredTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
MessageBodyTests.cs (1)
850var logEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (11)
InMemoryTransportBenchmark.cs (1)
135private readonly TaskCompletionSource<ConnectionContext> _tcs = new TaskCompletionSource<ConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
420stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 475internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1158_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159_disposingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Tests (2)
KestrelConfigurationLoaderTests.cs (2)
889var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 988var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (10)
QuicConnectionContextTests.cs (5)
119var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 170var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 213var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 574var pauseCompleteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 575var allConnectionsOnServerTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
QuicStreamContextTests.cs (2)
269var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 347var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
2036_stopTcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\InvocationRequest.cs (1)
130private readonly TaskCompletionSource<object?> _completionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\MessageBuffer.cs (1)
250var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
HubConnectionTests.cs (18)
1357var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1411var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2149var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2150var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2209var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2210var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2275var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2276var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2549var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2561tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2608var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2638tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2678var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2714tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2766var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2852var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2864tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2873var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Tests (65)
HttpConnectionTests.cs (1)
170var negotiateUrlTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.Negotiate.cs (3)
281var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously); 385var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously); 450var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.Transport.cs (6)
357var startSendTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 358var longPollTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 380var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 467var sendFinishedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 532var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.cs (9)
88var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 108var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var methodCalledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 710var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 727var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 815var resultTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 825var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1035private TaskCompletionSource _disableReconnect = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.Protocol.cs (2)
736var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 916var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.Reconnect.cs (38)
46var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 79var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 127var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 128var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 129var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 193var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 228var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 229var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 288var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 323var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 324var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 403var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 404var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 405var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 444reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 445reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 501var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 502var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 503var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 575var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 639var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 746var secondRetryDelayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 764var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 765var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 766var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 853var secondRetryDelayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 871var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 872var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 873var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 968var connectionStartTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 978connectionStartTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 997var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 998var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1075var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1076var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1121public TaskCompletionSource<TestConnection> _testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously); 1150_testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously); 1159_testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously);
LongPollingTransportTests.cs (1)
705var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
SendUtilsTests.cs (1)
20var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
ServerSentEventsTransportTests.cs (1)
418var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TimerAwaitableTests.cs (1)
18var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Core (3)
HubConnectionContext.cs (1)
31private readonly TaskCompletionSource _abortCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
src\SignalR\common\Shared\MessageBuffer.cs (1)
250var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
Internal\AckHandler.cs (1)
92Tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.AspNetCore.SignalR.Tests (18)
DefaultHubLifetimeManagerTests.cs (9)
43var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 69var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 93var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 138var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 165var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 219var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 249var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTests.cs (3)
2941_waitForRead = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2971_waitForRead = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5336private TaskCompletionSource _reconnectDisabled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTestUtils\Hubs.cs (4)
307var tcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 331var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1202StartedMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 1203EndMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
CancellationTokenExtensions.cs (1)
10var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.StaticFiles.FunctionalTests (3)
StaticFileMiddlewareTests.cs (3)
238var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 239var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 240var responseComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.TestHost (1)
HttpContextBuilder.cs (1)
16private readonly TaskCompletionSource<HttpContext> _responseTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.TestHost.Tests (36)
ClientHandlerTests.cs (8)
200var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 295var hasStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 296var hasAssertedResponseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 403var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 422var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 463var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 521var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpContextBuilderTests.cs (8)
118var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 169var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 191var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 217var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 240var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 281var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 328var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestLifetimeTests.cs (6)
18var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 36var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 52var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 53var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 75var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 76var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseBodyTests.cs (1)
126var emptyReadStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseResetTests.cs (6)
69var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 90var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 110var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 135var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 136var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TestClientTests.cs (5)
346var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 408var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 456var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 829var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 862var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Tests (2)
WebApplicationTests.cs (1)
1368var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WebHostTests.cs (1)
44var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.WebSockets.Tests (4)
WebSocketMiddlewareTests.cs (4)
139var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 171var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 211tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.DotNet.Open.Api.Tools.Tests (1)
ProcessEx.cs (1)
37_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.ApiDescription.Client.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Hybrid (2)
Internal\DefaultHybridCache.StampedeStateT.cs (2)
25_result = new(TaskCreationOptions.RunContinuationsAsynchronously); 257var cancelStub = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Diagnostics.HealthChecks.Tests (17)
DefaultHealthCheckServiceTest.cs (4)
489var input1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 490var input2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 491var output1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 492var output2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
HealthCheckPublisherHostedServiceTest.cs (13)
99var unblock0 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 100var unblock1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 101var unblock2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 144var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 187var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 241var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 242var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 398var unblock0 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 399var unblock1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 400var unblock2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 451var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 505var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 800_started = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Hosting.WindowsServices (2)
WindowsServiceLifetime.cs (2)
20private readonly TaskCompletionSource<object?> _delayStart = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 21private readonly TaskCompletionSource<object?> _serviceDispatcherStopped = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Sockets.BindTests (2)
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)
64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously);
Sockets.FunctionalTests (64)
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)
64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
59var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\Http2\ShutdownTests.cs (8)
52var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 53var readFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 54var writeFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 116var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 117var requestStopping = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 173var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 174var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\MaxRequestBufferSizeTests.cs (4)
129var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 130var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 222var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 223var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (16)
196var ensureConcurrentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 625var appDoneTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 721var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 722var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 756var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 792var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 837var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 838var registrationTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 930var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 931var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 932var serverFinConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 933var serverRstConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 934var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1032var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1033var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (32)
157var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 159var appCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 206var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 207var requestAbortedWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208var requestStartWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 266var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 267var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 268var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 269var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 361var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 362var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 469var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 470var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 471var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 601var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 602var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 603var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 604var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 605var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 606var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 719var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 720var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 721var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 722var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 723var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 724var copyToAsyncCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 840var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1001var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)
44var serverConnectionCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Diagnostics.Process (1)
System\Diagnostics\Process.cs (1)
1535var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Http (4)
src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
358_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1132: base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
133_expect100ContinueWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Quic (2)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
313_finalTaskSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Quic\QuicConnection.cs (1)
114private TaskCompletionSource _connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Security (1)
System\Net\Security\SslStream.IO.cs (1)
785_handshakeWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.WebSockets (1)
System\Net\WebSockets\AsyncMutex.cs (1)
235public Waiter(AsyncMutex owner) : base(TaskCreationOptions.RunContinuationsAsynchronously) => Owner = owner;
System.Private.CoreLib (7)
src\libraries\System.Private.CoreLib\src\System\Threading\SemaphoreSlim.cs (1)
72internal TaskNode() : base((object?)null, TaskCreationOptions.RunContinuationsAsynchronously) { }
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (4)
332if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 551TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 3443(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 5828thisRef.AtomicStateUpdate((int)TaskCreationOptions.RunContinuationsAsynchronously, 0);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (1)
207TaskCreationOptions.RunContinuationsAsynchronously)) != 0)
src\libraries\System.Private.CoreLib\src\System\Threading\Timer.cs (1)
657var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.Threading.Channels (3)
System\Threading\Channels\BoundedChannel.cs (1)
53_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
45_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedChannel.cs (1)
37_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System.Threading.RateLimiting (5)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
427: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)
21private readonly TaskCompletionSource<object?> _disposeComplete = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
464: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
477: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
478: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (1)
1488base(TaskCreationOptions.RunContinuationsAsynchronously)
Blocks\BroadcastBlock.cs (1)
504private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Blocks\WriteOnceBlock.cs (2)
83_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 502Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
Internal\SourceCore.cs (1)
36private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.WebAssembly.Auth.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.WebAssembly.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Mvc.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);