1039 references to RunContinuationsAsynchronously
aspire (1)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
534var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Cli.Tests (2)
Commands\PublishCommandPromptingIntegrationTests.cs (1)
754var completionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\RunCommandTests.cs (1)
1356var tcs = new TaskCompletionSource<Dictionary<string, string>>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard (9)
Components\Dialogs\AssistantModalDialog.razor.cs (1)
49_disconnectTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Components\Interactions\InteractionsProvider.cs (2)
48private TaskCompletionSource _interactionAvailableTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 599_interactionAvailableTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Components\Pages\Resources.razor.cs (2)
119private readonly TaskCompletionSource _loadingTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 657_contextMenuClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ServiceClient\DashboardClient.cs (4)
49private readonly TaskCompletionSource _whenConnectedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 50private readonly TaskCompletionSource _initialDataReceivedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 53private readonly TaskCompletionSource _resourceWatchCompleteTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 54private readonly TaskCompletionSource _interactionWatchCompleteTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Components.Tests (13)
Layout\MainLayoutTests.cs (4)
33var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 53var dismissedSettingSetTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 94var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 147var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\ConsoleLogsTests.cs (6)
60var targetLocationTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 330var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 378var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 427var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 594var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 658var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\LoginTests.cs (1)
32var tcs = new TaskCompletionSource<AuthenticationState>(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\MetricsTests.cs (1)
59var targetLocationTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\ResourcesTests.cs (1)
684var connectionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Tests (13)
Integration\OtlpGrpcServiceTests.cs (1)
199var tcs = new TaskCompletionSource<DashboardOptions>(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceOutgoingPeerResolverTests.cs (1)
130var tcs = new TaskCompletionSource<ResourceViewModelSubscription>(TaskCreationOptions.RunContinuationsAsynchronously);
Telemetry\DashboardTelemetryServiceTests.cs (1)
99var tcs = new TaskCompletionSource<PostOperationRequest>(TaskCreationOptions.RunContinuationsAsynchronously);
TelemetryRepositoryTests\LogTests.cs (3)
451var newResourcesTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 489var newLogsTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 575var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
168var tcs = new TaskCompletionSource<WriteContext>(TaskCreationOptions.RunContinuationsAsynchronously); 389var firstSpanReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 447var watchStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 507var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 564var watchStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 787var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 878var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting (8)
ApplicationModel\ValueSnapshot.cs (1)
21new(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\AuxiliaryBackchannelService.cs (1)
25private readonly TaskCompletionSource _listeningTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Health\ResourceHealthCheckService.cs (1)
365_delayInterruptTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InteractionService.cs (1)
517public TaskCompletionSource<InteractionCompletionState> CompletionTcs { get; } = new TaskCompletionSource<InteractionCompletionState>(TaskCreationOptions.RunContinuationsAsynchronously);
Orchestrator\ParameterProcessor.cs (3)
50parameterResource.WaitForValueTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 400var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 423parameterResource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Pipelines\DistributedApplicationPipeline.cs (1)
605stepCompletions[step.Name] = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure (4)
AzureBicepResource.cs (1)
47ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
AzureEnvironmentResource.cs (1)
56internal TaskCompletionSource<ProvisioningContext> ProvisioningContextTask { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
Provisioning\Internal\RunModeProvisioningContextProvider.cs (1)
40private readonly TaskCompletionSource _provisioningOptionsAvailable = new(TaskCreationOptions.RunContinuationsAsynchronously);
Provisioning\Provisioners\AzureProvisioner.cs (1)
141r.AzureResource!.ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure.Tests (1)
AzureSignalREmulatorFunctionalTest.cs (1)
111var messageTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
234var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Testing (4)
DistributedApplicationFactory.cs (4)
25private readonly TaskCompletionSource _startedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 26private readonly TaskCompletionSource _exitTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 27private readonly TaskCompletionSource<DistributedApplicationBuilder> _builderTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 28private readonly TaskCompletionSource<DistributedApplication> _appTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (52)
AppHostSmokeTests.cs (1)
55var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Cli\CliOrphanDetectorTests.cs (7)
41var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 68var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 90var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 160var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 185var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 244var resourcesCreatedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Dashboard\ResourcePublisherTests.cs (1)
36var tcs = new TaskCompletionSource<IReadOnlyList<ResourceSnapshotChange>>(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\DcpExecutorTests.cs (1)
1238var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
DistributedApplicationTests.cs (2)
264var resourcesCreatedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 587var tcs = new TaskCompletionSource<DistributedApplicationModel>(TaskCreationOptions.RunContinuationsAsynchronously);
Eventing\DistributedApplicationBuilderEventingTests.cs (2)
177var beforeResourceStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 314var resourceStoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Health\ResourceHealthCheckServiceTests.cs (4)
57var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 175var monitorStoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 564var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 612var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InteractionServiceTests.cs (2)
813var updateTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 866var updateTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Orchestrator\ParameterProcessorTests.cs (13)
193param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 282parameterWithMissingValue.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 377parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 429param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 473secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 506param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 545param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 904parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 948parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 981parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1250connectionStringParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1291regularParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1335customParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceLoggerServiceTests.cs (1)
381var watchStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WithUrlsTests.cs (18)
53var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 85var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 110var tcs = new TaskCompletionSource<IServiceProvider>(TaskCreationOptions.RunContinuationsAsynchronously); 139var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 163var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 217var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 249var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 294var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 317var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 340var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 697var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 725var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 815var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 847var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 895var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 925var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
GenerateDocumentationAndConfigFiles (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
GetDocument.Insider (1)
Commands\GetDocumentCommandWorker.cs (1)
81var waitForStartTcs = new TaskCompletionSource<object>(TaskCreationOptions.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 (256)
ChunkedRequestTests.cs (4)
924var readStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 926var exTcs = new TaskCompletionSource<BadHttpRequestException>(TaskCreationOptions.RunContinuationsAsynchronously); 1196var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1237var tcs = new TaskCompletionSource(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); 110var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 177var openedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 178var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionMiddlewareTests.cs (1)
210var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2ConnectionTests.cs (37)
407var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 499var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 523appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 585var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1184var stream1Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1185var stream1ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1186var stream3Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1187var stream3ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1747var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1802var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2004var connectionAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2005var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2304var firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2305var finishFirstRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2306var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2307var finishSecondRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2513var requestBlocker = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3220var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3221var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3340var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3341var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3537var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3564var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3591var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3615var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4246var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4247var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4350var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4351var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4600var backpressureObservedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4601var backpressureReleasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4786var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5189var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5597var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5676var tcs = new TaskCompletionSource<byte[]>(TaskCreationOptions.RunContinuationsAsynchronously); 5924var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5978var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2KeepAliveTests.cs (2)
273var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 327var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2StreamTests.cs (48)
1582var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3821var writeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4287var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4730var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4731var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4732var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4783var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4784var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4785var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4850var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4851var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4904var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4905var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4906var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4970var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4971var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4972var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5026var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5027var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5028var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5140var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5141var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5142var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5219var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5220var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5221var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5293var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5294var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5295var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5363var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5364var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5365var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5434var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5435var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5436var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5437var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5519var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5520var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5521var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5522var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5608var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5609var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5610var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5611var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5695var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5696var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5697var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5698var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TestBase.cs (7)
135protected readonly TaskCompletionSource _closingStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 136protected readonly TaskCompletionSource _closedStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 617var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 651var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 693var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 738var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TimeoutTests.cs (3)
73var setTimeoutTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 327private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 918var backpressureTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2WebSocketTests.cs (1)
519var finishedSendingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3ConnectionTests.cs (5)
38var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 682var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 744var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 746var abortTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3StreamTests.cs (54)
711var headersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1127var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1128var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1129var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1174var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1175var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1176var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1227var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1228var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1274var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1275var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1276var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1327var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1328var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1329var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1376var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1377var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1378var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1469var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1470var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1471var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1529var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1530var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1531var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1584var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1585var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1586var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1641var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1642var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1643var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1699var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1700var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1701var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1758var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1759var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1760var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1822var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1823var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1824var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1885var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1886var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1887var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2012var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2044var readTrailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2838var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2839var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2840var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3074var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3075var startedReadingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3108var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3116tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3124tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3287var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3TimeoutTests.cs (2)
396}, null, true, new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 423private 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)
22private readonly TaskCompletionSource _firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 312var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KestrelMetricsTests.cs (9)
216var getNotificationFeatureTcs = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 236var waitForConnectionCloseRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 281var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 282var requestReceivedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 401var finishedSendingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var getNotificationFeatureTcs = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 584var waitForConnectionCloseRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestBodyTimeoutTests.cs (4)
28var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 112var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var appRunningTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 159var exceptionSwallowedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (11)
112var helloTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 113var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 231var pathTcs = new TaskCompletionSource<PathString>(TaskCreationOptions.RunContinuationsAsynchronously); 232var rawTargetTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 233var queryTcs = new TaskCompletionSource<IQueryCollection>(TaskCreationOptions.RunContinuationsAsynchronously); 1160var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1161var tcs2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1628var appEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1629var delayEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1900var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1997var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseDrainingTests.cs (1)
38var outputBufferedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (29)
39TaskCompletionSource onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 149var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 150var writeBlockedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 216var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var delayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 442var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 675var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 713var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 792var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 834var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 903var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1105var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1216var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1439var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1530var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1688var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1723var responseWritten = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2719var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2764var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3037var closeTaskTcs = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 3326var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3507var onStartingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3558var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4060var middlewareCompletionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4761var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4811var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4876var disposedTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (10)
439stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 461stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 492internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 493internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 494internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 495internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 496internal TaskCompletionSource OnDecoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 497internal TaskCompletionSource OnEncoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1182_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1183_disposingTcs = 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);
TestTransport\InMemoryTransportConnection.cs (2)
22private readonly TaskCompletionSource _waitForCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 116private 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);
InProcessWebSite (2)
Startup.cs (2)
1738private TaskCompletionSource _http3_ResetAfterHeadersCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1761private TaskCompletionSource _http3_AppExceptionAfterHeaders_InternalErrorCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Interop.FunctionalTests (65)
H2SpecCommands.cs (1)
242var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2RequestTests.cs (1)
96var protocolTcs = new TaskCompletionSource<SslProtocols>(TaskCreationOptions.RunContinuationsAsynchronously);
Http2WebSocketInteropTests.cs (1)
100var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3RequestTests.cs (29)
36private readonly TaskCompletionSource _completeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 37private readonly TaskCompletionSource<Stream> _getStreamTcs = new TaskCompletionSource<Stream>(TaskCreationOptions.RunContinuationsAsynchronously); 236var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 456var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 457var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 538var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 539var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 656var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 657var writeAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 889var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 890var requestStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1123var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1124var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1226var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1320var writingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1321var cancelTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1322var completionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1445var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1837var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1838var connectionStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1902var connectionStartedTcs1 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1904var connectionStartedTcs2 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1906var connectionStartedTcs3 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 2007var connectionStartedTcs = new TaskCompletionSource<MultiplexedConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 2146var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 2147var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 2148var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2267var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 2268var 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\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_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);
InteropTests (3)
Helpers\ClientProcess.cs (1)
22_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Helpers\WebsiteProcess.cs (1)
27_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Metrics (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Metrics.Legacy (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.AspNetCore.Components (2)
Routing\Router.cs (2)
346var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 357var cancellationTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Server.Tests (2)
Circuits\CircuitHostTest.cs (1)
982_renderTcsArray[i] = new(TaskCreationOptions.RunContinuationsAsynchronously);
Circuits\CircuitRegistryTest.cs (1)
502PauseInvoked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously),
Microsoft.AspNetCore.Components.Tests (5)
RendererTest.cs (5)
2386var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2431var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2470var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2506var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4297var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Web.Tests (1)
Media\ImageTest.cs (1)
197var tcs = new TaskCompletionSource<TValue>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.WebView.WindowsForms (2)
WindowsFormsDispatcher.cs (2)
80 var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 148 var tcs = new TaskCompletionSource<TResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Diagnostics.Tests (1)
ExceptionHandlerMiddlewareTest.cs (1)
554var tcs = new TaskCompletionSource<IExceptionHandlerPathFeature>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.FunctionalTests (1)
WebApplicationFunctionalTests.cs (1)
139var configChangedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (2)
Infrastructure\SyncPoint.cs (1)
13var taskCreationOptions = runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None;
UnaryServerCallHandlerTests.cs (1)
1248var tcs = new TaskCompletionSource<float?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Hosting.FunctionalTests (3)
ShutdownTests.cs (2)
67var startedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 68var 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); 4041_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)
954var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 955var blocker2 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1017var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1018var 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)
662var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 708var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 812var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 867new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 868new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 869new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 870new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 871new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 937new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 938new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 939new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 940new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 941new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1001new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1002new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1003new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1004new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1005new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1216var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Routing (1)
EndpointRoutingMiddleware.cs (1)
253var initialization = new TaskCompletionSource<Matcher>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys (3)
MessagePump.cs (2)
28private readonly TaskCompletionSource _acceptLoopsCompleted = new(TaskCreationOptions.RunContinuationsAsynchronously); 33private readonly TaskCompletionSource _requestsDrained = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (86)
AuthenticationTests.cs (1)
170var completed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2Tests.cs (7)
655var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 697var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 744var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 794var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 846var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 892var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 941var 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)
26var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 55var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 85var 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)
501var registered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 502var result = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 550var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 551var 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)
39var appThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 371var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 399var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 427var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 454var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 484var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 534var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 577var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 579var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 580var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 633var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 634var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 635var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 636var 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); 488var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 489var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 524var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 525var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 560var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 561var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpServer.cs (1)
34private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IISIntegration.Tests (8)
IISMiddlewareTests.cs (8)
104var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 105var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 163var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 164var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 209var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 253var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 254var 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 (7)
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)
101var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\KestrelServerImpl.cs (1)
32private readonly TaskCompletionSource _stoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (24)
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)
666var unbindTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 774changeCallbackRegisteredTcs = 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);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (12)
InMemoryTransportBenchmark.cs (1)
135private readonly TaskCompletionSource<ConnectionContext> _tcs = new TaskCompletionSource<ConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (10)
439stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 461stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 492internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 493internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 494internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 495internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 496internal TaskCompletionSource OnDecoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 497internal TaskCompletionSource OnEncoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1182_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1183_disposingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Tests (2)
KestrelConfigurationLoaderTests.cs (2)
1165var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1264var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_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); 577var pauseCompleteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var allConnectionsOnServerTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
QuicStreamContextTests.cs (2)
270var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 348var 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.SignalR.Client.Core (3)
HubConnection.cs (1)
2253_stopTcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\InvocationRequest.cs (1)
169private readonly TaskCompletionSource<object?> _completionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\MessageBuffer.cs (1)
251var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
HubConnectionTests.cs (18)
1363var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1417var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2155var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2156var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2215var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2216var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2281var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2282var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2557var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2569tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2616var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2646tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2686var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2722tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2774var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2860var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2872tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2881var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Tests (66)
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)
764var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 944var 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);
HubConnectionTests.Tracing.cs (1)
172var clientActivityTcs = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); ;
LongPollingTransportTests.cs (1)
705var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
SendUtilsTests.cs (1)
20var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
ServerSentEventsTransportTests.cs (1)
412var 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)
251var 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.StackExchangeRedis.Tests (4)
RedisEndToEnd.cs (4)
246reconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 247startedReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 365private TaskCompletionSource<(WebSocketReceiveResult, ReadOnlyMemory<byte>)> _receiveTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 414_receiveTcs = new(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); 5354private TaskCompletionSource _reconnectDisabled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTestUtils\Hubs.cs (4)
308var tcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 332var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1221StartedMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 1222EndMethod = 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)
201var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 296var hasStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 297var hasAssertedResponseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 406var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 425var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 444var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 466var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 524var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpContextBuilderTests.cs (8)
167var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 203var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 236var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 267var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 302var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 334var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 391var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 457var 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)
440var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 512var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 571var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1008var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1051var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Tests (2)
WebApplicationTests.cs (1)
1370var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WebHostTests.cs (1)
46var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.WebSockets.Tests (5)
WebSocketMiddlewareTests.cs (5)
139var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 171var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 211tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 802var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis (6)
DiagnosticAnalyzer\AsyncQueue.cs (6)
24private readonly TaskCompletionSource<bool> _whenCompleted = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 102Debug.Assert(waiter.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 200Debug.Assert(tcs.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 205Debug.Assert(_whenCompleted.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 281var waiter = new TaskCompletionSource<Optional<TElement>>(TaskCreationOptions.RunContinuationsAsynchronously); 316Debug.Assert(taskCompletionSource.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously));
Microsoft.CodeAnalysis.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.BannedApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.EditorFeatures (2)
DocumentationComments\DocumentationCommentSuggestion.cs (1)
173var taskCompletionSource = new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
IWpfDifferenceViewerExtensions.cs (1)
53var completionSource = new TaskCompletionSource<IProjectionSnapshot>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.InteractiveHost (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.LanguageServer (1)
BrokeredServices\WrappedServiceBroker.cs (1)
25private readonly TaskCompletionSource<IServiceBroker> _serviceBrokerTask = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.LanguageServer.Protocol (1)
Handler\Diagnostics\AbstractWorkspacePullDiagnosticsHandler.cs (1)
152var waiter = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.PublicApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.Workspaces (2)
Shared\TestHooks\AsynchronousOperationListener.cs (1)
174var source = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
Rpc\RpcClient.cs (1)
142var requestCompletionSource = new TaskCompletionSource<object?>(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.AsyncState.Tests (8)
AsyncStateTests.cs (8)
47var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 48var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 49var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 97var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 98var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 99var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 148var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 180var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Hybrid (2)
Internal\DefaultHybridCache.StampedeStateT.cs (2)
36_result = new(TaskCreationOptions.RunContinuationsAsynchronously); 90var 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)
100var unblock0 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 101var unblock1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 102var unblock2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 145var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 188var 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); 506var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 801_started = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Diagnostics.Testing (2)
Logging\FakeLogCollector.cs (1)
156_logEnumerationSharedWaiter = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Logging\FakeLogCollector.LogEnumeration.cs (1)
16new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Diagnostics.Testing.Tests (2)
Logging\FakeLogCollectorTests.LogEnumeration.cs (1)
101var abcProcessedAB = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\LegacySupport\TaskWaitAsync\TaskExtensions.cs (1)
39var tcs = new TaskCompletionSource<TResult>(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);
Microsoft.Extensions.ServiceDiscovery (2)
Http\HttpServiceEndpointResolver.cs (1)
234Interlocked.CompareExchange(ref _onDisposed, new(TaskCreationOptions.RunContinuationsAsynchronously), null);
ServiceEndpointResolver.cs (1)
226Interlocked.CompareExchange(ref _onDisposed, new(TaskCreationOptions.RunContinuationsAsynchronously), null);
Microsoft.Extensions.Validation.GeneratorTests (1)
ValidationsGeneratorTestBase.cs (1)
175var waitForStartTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.ML.Core (1)
Utilities\ThreadUtils.cs (1)
61var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.VisualStudio.LanguageServices (2)
ProjectSystem\FileChangeWatcherProvider.cs (1)
38TaskCreationOptions.RunContinuationsAsynchronously,
Remote\VisualStudioRemoteHostClientProvider.cs (1)
101private readonly TaskCompletionSource<bool> _clientCreationSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
Roslyn.Diagnostics.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(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 (67)
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)
53var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\Http2\ShutdownTests.cs (8)
46var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 47var readFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48var writeFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 110var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 111var requestStopping = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 166var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 167var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\MaxRequestBufferSizeTests.cs (4)
123var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 124var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 216var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 217var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (19)
198var ensureConcurrentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var appErrorLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 406var badRequestLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 407var connectionStoppedLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 695var appDoneTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 702var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 797var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 798var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 832var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 868var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 913var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 914var registrationTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 1006var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1007var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1008var serverFinConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1009var serverRstConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1010var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1108var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1109var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (32)
150var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 151var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 152var appCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 199var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 200var requestAbortedWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 201var 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); 362var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 363var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 484var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 616var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 617var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 619var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 620var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 621var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 734var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 735var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 736var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 737var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 738var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 739var copyToAsyncCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 860var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1021var 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)
1537var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
1084: base(TaskCreationOptions.RunContinuationsAsynchronously)
System.Net.Http (5)
src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
367_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1148: base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
133_expect100ContinueWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (1)
259_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Quic (2)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
321_finalTaskSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Quic\QuicConnection.cs (1)
143private readonly TaskCompletionSource _connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Security (1)
System\Net\Security\SslStream.IO.cs (1)
836_handshakeWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.WebSockets (1)
System\Net\WebSockets\AsyncMutex.cs (1)
249public 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)
406if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 626TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 3548(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 5940thisRef.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)
651var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.ServiceModel.Http (1)
System\ServiceModel\Channels\MessageContent.cs (1)
31_writeCompletedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.ServiceModel.Primitives (8)
Internals\System\Runtime\ServiceModelSynchronizationContext.cs (1)
16Task.Factory.StartNew((s) => d(s), state, default, TaskCreationOptions.RunContinuationsAsynchronously, IOThreadScheduler.IOTaskScheduler);
Internals\System\Runtime\TimeoutHelper.cs (1)
313var tcs = new TaskCompletionSource<CancellationToken>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\CommunicationObject.cs (2)
327await Task.Factory.FromAsync(OnBeginClose, OnEndClose, timeout, TaskCreationOptions.RunContinuationsAsynchronously); 576await Task.Factory.FromAsync(OnBeginOpen, OnEndOpen, timeout, TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (1)
48_tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (1)
785_tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ServiceChannelProxy.cs (2)
213TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 318return new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
62_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\RendezvousChannel.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)
39_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
44_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System.Threading.RateLimiting (5)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
422: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)
21private readonly TaskCompletionSource<object?> _disposeComplete = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
460: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
473: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
474: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (1)
1455base(TaskCreationOptions.RunContinuationsAsynchronously)
Blocks\BroadcastBlock.cs (1)
498private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Blocks\WriteOnceBlock.cs (2)
80_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 495Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
Internal\SourceCore.cs (1)
36private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Windows.Forms (6)
System\Windows\Forms\Control_InvokeAsync.cs (4)
64TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 189TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 290TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 395TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Windows\Forms\Form.cs (2)
5610TaskCreationOptions.RunContinuationsAsynchronously); 5910creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
System.Windows.Forms.UI.IntegrationTests (4)
Infra\ControlTestBase.cs (3)
137TaskCompletionSource<VoidResult> idleCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 298TaskCompletionSource<VoidResult> gate = new(TaskCreationOptions.RunContinuationsAsynchronously); 344TaskCompletionSource<VoidResult> gate = new(TaskCreationOptions.RunContinuationsAsynchronously);
MonthCalendarTests.cs (1)
146TaskCompletionSource<VoidResult> dateChanged = new(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);
Test.Utilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Text.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)