1417 references to TaskCreationOptions
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);
Client.ChannelLayer.IntegrationTests (18)
DuplexChannelShapeTests.4.0.0.cs (6)
93Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 97Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 110TaskCreationOptions.None).GetAwaiter().GetResult(); 111replyMessage = Task.Factory.FromAsync(channel.BeginReceive, channel.EndReceive, TaskCreationOptions.None).GetAwaiter().GetResult(); 125Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 126Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
DuplexChannelWithSynchronizationContext.cs (2)
155Task.Factory.StartNew(() => SingleThreadedSyncContext_CallbackUsingDefaultSyncCtx_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 220Task.Factory.StartNew(() => SingleThreadedSyncContext_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
RequestReplyChannelShapeTests.4.0.0.cs (10)
143Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 147Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 159TaskCreationOptions.None).GetAwaiter().GetResult(); 171Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 172Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 199Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 203Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 215TaskCreationOptions.None).GetAwaiter().GetResult(); 228Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 229Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
Client.TypedClient.IntegrationTests (5)
TypedProxyTests.4.0.0.cs (3)
72Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 106Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 160Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_Synchronous_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
TypedProxyTests.4.1.0.cs (2)
26Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 40Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
Consumer (1)
ConsumerWorker.cs (1)
39}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Contract.Service.IntegrationTests (13)
ServiceContractTests.4.0.0.cs (8)
307Task t = Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None); 336Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 361Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginOpen, proxyAsCommunicationObject.EndOpen, TaskCreationOptions.None); 389Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 416Task t = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None); 440Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 465Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginClose, proxyAsCommunicationObject.EndClose, TaskCreationOptions.None); 490Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
ServiceContractTests.4.1.0.cs (5)
210Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 224Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed_Async(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 614Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 628Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 879Task factoryTask = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None);
dotnet-svcutil-lib (3)
FrameworkFork\System.ServiceModel\Internals\System\Runtime\ActionItem.cs (2)
37Task.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 67Task.Factory.StartNew(callback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1183Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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 (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Metrics.Legacy (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
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.Photino (1)
PhotinoWebViewManager.cs (1)
43}, message, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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.DataProtection (1)
KeyManagement\KeyRingProvider.cs (1)
370TaskCreationOptions.DenyChildAttach,
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 (4)
Infrastructure\SyncPoint.cs (3)
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.Extensions (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
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.Core (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
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.OpenApi (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.OutputCaching (2)
DispatcherExtensions.cs (2)
24var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously); 63var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)
RedisOutputCacheStore.cs (1)
88_ = Task.Factory.StartNew(RunGarbageCollectionLoopAsync, default, TaskCreationOptions.LongRunning, TaskScheduler.Current);
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.Shared.Tests (3)
ObjectMethodExecutorTest.cs (2)
347FSharpOption<TaskCreationOptions>.None, 365FSharpOption<TaskCreationOptions>.None,
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
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 (4)
HubConnectionContext.cs (1)
31private readonly TaskCompletionSource _abortCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
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.SpaServices.Extensions (1)
Util\EventedStreamReader.cs (1)
30Task.Factory.StartNew(Run, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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 (2)
HttpContextBuilder.cs (2)
16private readonly TaskCompletionSource<HttpContext> _responseTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 157_ = Task.Factory.StartNew(RunRequestAsync, default, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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 (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.BannedApiAnalyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.CodeStyle (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
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.EditorFeatures.Test.Utilities (1)
Threading\WpfTestRunner.cs (1)
82}, CancellationTokenSource.Token, TaskCreationOptions.None, new SynchronizationContextTaskScheduler(sta.DispatcherSynchronizationContext));
Microsoft.CodeAnalysis.EditorFeatures.UnitTests (3)
Utilities\AsynchronousOperationListenerTests.cs (3)
68}, _tokenSource.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default); 304}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 314}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.InteractiveHost (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
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 (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.PublicApiAnalyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.Scripting.TestUtilities (3)
ObjectFormatterFixtures\MockDesktopTask.cs (3)
29public TaskCreationOptions CreationOptions => TaskCreationOptions.None; 41public TaskCreationOptions CreationOptions => m_task.CreationOptions;
Microsoft.CodeAnalysis.Workspaces (5)
FindSymbols\SymbolTree\SymbolTreeInfoCacheService.cs (1)
61=> Task.Factory.StartNew(createWorkAsync, cancellationToken, TaskCreationOptions.None, _scheduler).Unwrap();
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)
Storage\SQLite\v2\SQLitePersistentStorage_Threading.cs (1)
24var task = Task.Factory.StartNew(boundFunction, cancellationToken, TaskCreationOptions.None, scheduler);
Workspace\Workspace.cs (1)
721}, cancellationToken, TaskCreationOptions.None, _taskSchedulerProvider.CurrentContextScheduler).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
Rpc\RpcClient.cs (1)
142var requestCompletionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.Workspaces.UnitTests (1)
UtilityTest\AsyncLazyTests.cs (1)
78}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Current);
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.Caching.Memory (3)
CacheEntry.CacheEntryTokens.cs (1)
110CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
CacheEntry.cs (1)
288}, obj, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
MemoryCache.cs (1)
398CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.DependencyInjection (1)
ServiceLookup\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew((Func<object?, R>)action, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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.FileProviders.Physical (1)
PhysicalFilesWatcher.cs (1)
456TaskCreationOptions.DenyChildAttach,
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.Extensibility.Testing.Xunit (3)
src\VisualStudio\IntegrationTest\Harness\XUnitShared\Harness\IdeTestAssemblyRunner.cs (1)
208TaskCreationOptions.None,
src\VisualStudio\IntegrationTest\Harness\XUnitShared\Threading\InProcessIdeTestRunner.cs (1)
39TaskCreationOptions.None,
src\VisualStudio\IntegrationTest\Harness\XUnitShared\Threading\SemaphoreExtensions.cs (1)
37TaskCreationOptions.LongRunning,
Microsoft.VisualStudio.LanguageServices (2)
ProjectSystem\FileChangeWatcherProvider.cs (1)
38TaskCreationOptions.RunContinuationsAsynchronously,
Remote\VisualStudioRemoteHostClientProvider.cs (1)
101private readonly TaskCompletionSource<bool> _clientCreationSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1165[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
netstandard (1)
netstandard.cs (1)
2123[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
OrderProcessor (1)
OrderProcessingWorker.cs (1)
43}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Roslyn.Diagnostics.Analyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Roslyn.VisualStudio.DiagnosticsWindow (1)
OptionPages\ForceLowMemoryMode.cs (1)
80return Task.Factory.StartNew(() => this.PopulateAndMonitorWorkerAsync(size), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default).Unwrap();
Security.TransportSecurity.IntegrationTests (2)
Tcp\StreamingTests.4.1.0.cs (2)
385Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 403Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
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.ComponentModel.EventBasedAsync (1)
System\ComponentModel\BackgroundWorker.cs (1)
132TaskCreationOptions.DenyChildAttach,
System.Diagnostics.Process (1)
System\Diagnostics\Process.cs (1)
1537var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.IO.Pipes (1)
System\IO\Pipes\NamedPipeClientStream.cs (1)
202}, (this, timeout, cancellationToken, startTime), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.IO.Ports (2)
System\IO\Ports\SerialStream.Unix.cs (2)
685TaskCreationOptions.LongRunning, 1084: base(TaskCreationOptions.RunContinuationsAsynchronously)
System.Linq.Expressions (1)
System\Linq\Expressions\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew(action!, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Linq.Parallel (3)
System\Linq\Parallel\Scheduling\QueryTask.cs (3)
64Task task = new Task(s_runTaskSynchronouslyDelegate, this, TaskCreationOptions.AttachedToParent); 84return Task.Factory.StartNew(s_baseWorkDelegate, this, CancellationToken.None, TaskCreationOptions.AttachedToParent | TaskCreationOptions.PreferFairness, taskScheduler);
System.Net.Http (6)
src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
1002CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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.HttpListener (1)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
357TaskCreationOptions.DenyChildAttach,
System.Net.NetworkInformation (1)
System\Net\NetworkInformation\UnixIPGlobalProperties.cs (1)
57CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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.Requests (5)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
357TaskCreationOptions.DenyChildAttach,
System\Net\FileWebRequest.cs (4)
161this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 174}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 222this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 235}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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 (243)
src\libraries\System.Private.CoreLib\src\System\Diagnostics\Tracing\EventPipeEventDispatcher.Threads.cs (1)
18m_dispatchTask = Task.Factory.StartNew(() => DispatchEventsToEventListeners(sessionID, syncTimeUtc, syncTimeQPC, timeQPCFrequency, previousDispatchTask, m_dispatchTaskCancellationSource.Token), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default);
src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (2)
194cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 659base(function, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach)
src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (4)
223cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 281}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 288}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 311}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default));
src\libraries\System.Private.CoreLib\src\System\IO\TextWriter.cs (11)
593}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 611}, new TupleSlim<TextWriter, char, char>(this, valueChars[0], valueChars[1]), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 622}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 670}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 680}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 687}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 705}, new TupleSlim<TextWriter, char, char>(this, valueChars[0], valueChars[1]), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 716}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 765}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 775}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 793CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\TaskAwaiter.cs (2)
268if (innerEtwLog.TasksSetActivityIds && (innerTask.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 278if (innerEtwLog.TasksSetActivityIds && (innerTask.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0)
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (2)
110Task.Factory.StartNew(continuation, default, TaskCreationOptions.PreferFairness, scheduler); 143Task.Factory.StartNew(static s => ((IAsyncStateMachineBox)s!).MoveNext(), box, default, TaskCreationOptions.PreferFairness, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)
347}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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\ConcurrentExclusiveSchedulerPair.cs (4)
745internal static TaskCreationOptions GetCreationOptionsForTask(bool isReplacementReplica = false) 747TaskCreationOptions options = TaskCreationOptions.DenyChildAttach; 748if (isReplacementReplica) options |= TaskCreationOptions.PreferFairness;
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (1)
313Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (83)
370internal Task(bool canceled, TaskCreationOptions creationOptions, CancellationToken ct) 399internal Task(object? state, TaskCreationOptions creationOptions, bool promiseStyle) 406if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 412if ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 430: this(action, null, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 445: this(action, null, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 454/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 462/// cref="TaskCreationOptions"/>. 464public Task(Action action, TaskCreationOptions creationOptions) 475/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 483/// cref="TaskCreationOptions"/>. 488public Task(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 502: this(action, state, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 519: this(action, state, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 529/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 537/// cref="TaskCreationOptions"/>. 539public Task(Action<object?> action, object? state, TaskCreationOptions creationOptions) 551/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 559/// cref="TaskCreationOptions"/>. 564public Task(Action<object?> action, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 580TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 589if (parent != null && (creationOptions & TaskCreationOptions.AttachedToParent) != 0) 613TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 621~(TaskCreationOptions.AttachedToParent | 622TaskCreationOptions.LongRunning | 623TaskCreationOptions.DenyChildAttach | 624TaskCreationOptions.HideScheduler | 625TaskCreationOptions.PreferFairness | 626TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 661&& ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 662&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0)) 741((Options & TaskCreationOptions.AttachedToParent) != 0) 742&& ((parent.Options & TaskCreationOptions.DenyChildAttach) == 0)) 754internal TaskCreationOptions Options => OptionsMethod(m_stateFlags); 758internal static TaskCreationOptions OptionsMethod(int flags) 761return (TaskCreationOptions)(flags & (int)TaskStateFlags.OptionsMask); 815Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, 1033TaskCreationOptions options = OptionsMethod(flags); 1034if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 1038if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1125TaskCreationOptions options = OptionsMethod(flags); 1126if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1132if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 1220TaskCreationOptions options, InternalTaskOptions internalOptions) 1308internal static Task? InternalCurrentIfAttached(TaskCreationOptions creationOptions) 1310return (creationOptions & TaskCreationOptions.AttachedToParent) != 0 ? InternalCurrent : null; 1471/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions</see> used 1474public TaskCreationOptions CreationOptions => Options & (TaskCreationOptions)(~InternalTaskOptions.InternalOptionsMask); 1544internal static readonly Task<VoidTaskResult> s_cachedCompleted = new Task<VoidTaskResult>(false, default, (TaskCreationOptions)InternalTaskOptions.DoNotDispose, default); 1679if ((Options & (TaskCreationOptions)InternalTaskOptions.DoNotDispose) != 0) 1758(Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0 && 1783if ((Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0) 2024&& ((Options & TaskCreationOptions.AttachedToParent) != 0) 2025&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2219&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2220&& (((TaskCreationOptions)(m_stateFlags & (int)TaskStateFlags.OptionsMask)) & TaskCreationOptions.AttachedToParent) != 0) 3252Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) == 0, "Task.InternalCancel() did not expect promise-style task"); 3344Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, "Task.RecordInternalCancellationRequest(CancellationToken) only valid for promise-style task"); 3548(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 3869CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4051CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4251CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4455CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4479out TaskCreationOptions creationOptions, 4518creationOptions = (TaskCreationOptions)(continuationOptions & CreationOptionsMask); 4590if ((this.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0 && 5538return new Task(true, TaskCreationOptions.None, cancellationToken); 5549return new Task<TResult>(true, default, TaskCreationOptions.None, cancellationToken); 5594TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5612TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5626TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5644TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5683Task<Task?> task1 = Task<Task?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5727Task<Task<TResult>?> task1 = Task<Task<TResult>?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5940thisRef.AtomicStateUpdate((int)TaskCreationOptions.RunContinuationsAsynchronously, 0); 6332return new Task<TResult[]>(false, [], TaskCreationOptions.None, default); 6366new Task<TResult[]>(false, [], TaskCreationOptions.None, default) : 6443return new Task<TResult[]>(false, [], TaskCreationOptions.None, default); 7232public TaskCreationOptions CreationOptions => m_task.CreationOptions; 7471: base((object?)null, outerTask.CreationOptions & TaskCreationOptions.AttachedToParent)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task_T.cs (28)
73internal Task(object? state, TaskCreationOptions options) : 81base(false, TaskCreationOptions.None, default) 86internal Task(bool canceled, TResult? result, TaskCreationOptions creationOptions, CancellationToken ct) 107TaskCreationOptions.None, InternalTaskOptions.None, null) 128TaskCreationOptions.None, InternalTaskOptions.None, null) 140/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 148/// cref="TaskCreationOptions"/>. 150public Task(Func<TResult> function, TaskCreationOptions creationOptions) 164/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 172/// cref="TaskCreationOptions"/>. 177public Task(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 195TaskCreationOptions.None, InternalTaskOptions.None, null) 216TaskCreationOptions.None, InternalTaskOptions.None, null) 229/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 237/// cref="TaskCreationOptions"/>. 239public Task(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 256/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 264/// cref="TaskCreationOptions"/>. 269public Task(Func<object?, TResult> function, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 285TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 301TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 309TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 329TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 773out TaskCreationOptions creationOptions, 958out TaskCreationOptions creationOptions, 1172out TaskCreationOptions creationOptions, 1393out TaskCreationOptions creationOptions, 1426public TaskCreationOptions CreationOptions => m_task.CreationOptions;
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCache.cs (1)
28new Task<TResult>(false, result, (TaskCreationOptions)InternalTaskOptions.DoNotDispose, default);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCompletionSource.cs (3)
46public TaskCompletionSource(TaskCreationOptions creationOptions) : 55this(state, TaskCreationOptions.None) 63public TaskCompletionSource(object? state, TaskCreationOptions creationOptions) =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCompletionSource_T.cs (3)
49public TaskCompletionSource(TaskCreationOptions creationOptions) : 58this(state, TaskCreationOptions.None) 66public TaskCompletionSource(object? state, TaskCreationOptions creationOptions) =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskContinuation.cs (5)
15Task antecedent, Delegate action, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 61Task antecedent, Delegate function, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 107Task<TAntecedentResult> antecedent, Delegate action, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 153Task<TAntecedentResult> antecedent, Delegate function, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 554TaskCreationOptions.None, InternalTaskOptions.QueuedByRuntime, scheduler)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (52)
39private readonly TaskCreationOptions m_defaultCreationOptions; 49(currTask != null && (currTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0 ? currTask.ExecutingTaskScheduler! : // a "current" task must be executing, which means it must have a scheduler 64/// <see cref="TaskCreationOptions"/> property is initialized to 65/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 84/// <see cref="TaskCreationOptions"/> property is initialized to 85/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 107/// <see cref="TaskCreationOptions"/> property is initialized to 108/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 125/// The default <see cref="TaskCreationOptions"> 139/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 147public TaskFactory(TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions) 163/// The default <see cref="TaskCreationOptions"> 182/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 191public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 198internal static void CheckCreationOptions(TaskCreationOptions creationOptions) 202~(TaskCreationOptions.AttachedToParent | 203TaskCreationOptions.DenyChildAttach | 204TaskCreationOptions.HideScheduler | 205TaskCreationOptions.LongRunning | 206TaskCreationOptions.PreferFairness | 207TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 239/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions 246public TaskCreationOptions CreationOptions => m_defaultCreationOptions; 249/// Gets the <see cref="TaskCreationOptions">TaskContinuationOptions 329public Task StartNew(Action action, TaskCreationOptions creationOptions) 368public Task StartNew(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 452public Task StartNew(Action<object?> action, object? state, TaskCreationOptions creationOptions) 494TaskCreationOptions creationOptions, TaskScheduler scheduler) 583public Task<TResult> StartNew<TResult>(Func<TResult> function, TaskCreationOptions creationOptions) 626public Task<TResult> StartNew<TResult>(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 721public Task<TResult> StartNew<TResult>(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 767TaskCreationOptions creationOptions, TaskScheduler scheduler) 821TaskCreationOptions creationOptions) 852TaskCreationOptions creationOptions, 907Action<IAsyncResult> endMethod, object? state, TaskCreationOptions creationOptions) 973TArg1 arg1, object? state, TaskCreationOptions creationOptions) 1046TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1127TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1182IAsyncResult asyncResult, Func<IAsyncResult, TResult> endMethod, TaskCreationOptions creationOptions) 1214IAsyncResult asyncResult, Func<IAsyncResult, TResult> endMethod, TaskCreationOptions creationOptions, TaskScheduler scheduler) 1273Func<IAsyncResult, TResult> endMethod, object? state, TaskCreationOptions creationOptions) 1339Func<IAsyncResult, TResult> endMethod, TArg1 arg1, object? state, TaskCreationOptions creationOptions) 1413Func<IAsyncResult, TResult> endMethod, TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1496Func<IAsyncResult, TResult> endMethod, TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1506internal static void CheckFromAsyncOptions(TaskCreationOptions creationOptions, bool hasBeginMethod) 1511if ((creationOptions & TaskCreationOptions.LongRunning) != 0) 1513if ((creationOptions & TaskCreationOptions.PreferFairness) != 0) 1519~(TaskCreationOptions.AttachedToParent | 1520TaskCreationOptions.DenyChildAttach | 1521TaskCreationOptions.HideScheduler | 1522TaskCreationOptions.PreferFairness | 1523TaskCreationOptions.LongRunning)) != 0)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory_T.cs (34)
36private readonly TaskCreationOptions m_defaultCreationOptions; 46&& ((currTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0) 59/// <see cref="TaskCreationOptions"/> property is initialized to 60/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 79/// <see cref="TaskCreationOptions"/> property is initialized to 80/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 102/// <see cref="TaskCreationOptions"/> property is initialized to 103/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 120/// The default <see cref="TaskCreationOptions"> 134/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 142public TaskFactory(TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions) 158/// The default <see cref="TaskCreationOptions"> 177/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 186public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 219/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions 226public TaskCreationOptions CreationOptions => m_defaultCreationOptions; 229/// Gets the <see cref="TaskCreationOptions">TaskContinuationOptions 313public Task<TResult> StartNew(Func<TResult> function, TaskCreationOptions creationOptions) 353public Task<TResult> StartNew(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 438public Task<TResult> StartNew(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 480public Task<TResult> StartNew(Func<object?, TResult> function, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 588TaskCreationOptions creationOptions) 621TaskCreationOptions creationOptions, 633TaskCreationOptions creationOptions, 665default, TaskCreationOptions.None, InternalTaskOptions.None, null); 747Func<IAsyncResult, TResult> endMethod, object? state, TaskCreationOptions creationOptions) 756object? state, TaskCreationOptions creationOptions) 864TArg1 arg1, object? state, TaskCreationOptions creationOptions) 873TArg1 arg1, object? state, TaskCreationOptions creationOptions) 989TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 998TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1122TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1131TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1327Task.CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions tco, out _);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (1)
315&& ((currentTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ThreadPoolTaskScheduler.cs (3)
45TaskCreationOptions options = task.Options; 46if (RuntimeFeature.IsMultithreadingSupported && (options & TaskCreationOptions.LongRunning) != 0) 58ThreadPool.UnsafeQueueUserWorkItemInternal(task, (options & TaskCreationOptions.PreferFairness) == 0);
src\libraries\System.Private.CoreLib\src\System\Threading\Timer.cs (1)
651var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net11.0\System.Runtime.Forwards.cs (1)
835[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
System.ServiceModel.Federation (7)
System\Runtime\OperationWithTimeoutAsyncResult.cs (1)
25_ = Task.Factory.StartNew(s_scheduledCallback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\ServiceModel\Federation\WSTrustChannel.cs (1)
361Message response = await Task.Factory.FromAsync(RequestChannel.BeginRequest, RequestChannel.EndRequest, requestMessage, null, TaskCreationOptions.None).ConfigureAwait(false);
System\ServiceModel\Federation\WSTrustChannelSecurityTokenProvider.cs (5)
243await Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, null, TaskCreationOptions.None); 247Message reply = await Task.Factory.FromAsync(channel.BeginRequest, channel.EndRequest, requestMessage, null, TaskCreationOptions.None); 254await Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, null, TaskCreationOptions.None); 452await Task.Factory.FromAsync(ChannelFactory.BeginClose, ChannelFactory.EndClose, timeout, null, TaskCreationOptions.None); 469await Task.Factory.FromAsync(channelFactory.BeginOpen, channelFactory.EndOpen, null, TaskCreationOptions.None);
System.ServiceModel.Http (2)
System\ServiceModel\Channels\MessageContent.cs (2)
31_writeCompletedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 198}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.ServiceModel.NetFramingBase (1)
System\ServiceModel\Security\SecurityUtilsEx.cs (1)
92return Task.Factory.FromAsync(co.BeginClose, co.EndClose, timeout, null, TaskCreationOptions.None);
System.ServiceModel.Primitives (14)
Internals\System\Runtime\ActionItem.cs (1)
86Task<Task>.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, IOThreadScheduler.IOTaskScheduler);
Internals\System\Runtime\IOThreadScheduler.cs (1)
131Task.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
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\ServiceChannelFactory.cs (1)
504await Task.Factory.FromAsync(base.OnBeginClose, base.OnEndClose, timeoutHelper.RemainingTime(), TaskCreationOptions.None);
System\ServiceModel\Channels\ServiceChannelProxy.cs (2)
213TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 318return new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1202Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\ServiceModel\Security\SecurityUtils.cs (2)
516return Task.Factory.FromAsync(communicationObject.BeginOpen, communicationObject.EndOpen, timeout, null, TaskCreationOptions.None); 537return Task.Factory.FromAsync(communicationObject.BeginClose, communicationObject.EndClose, timeout, null, TaskCreationOptions.None);
System.Threading.Channels (12)
System\Threading\Channels\AsyncOperation.cs (2)
250CancellationToken.None, TaskCreationOptions.DenyChildAttach, ts); 386Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, ts);
System\Threading\Channels\BoundedChannel.cs (2)
62_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\RendezvousChannel.cs (2)
53_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (2)
45_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedChannel.cs (2)
39_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedPriorityChannel.cs (2)
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 (1)
System.Threading.Tasks.cs (1)
30[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
System.Threading.Tasks.Dataflow (12)
Base\DataflowBlock.cs (4)
1296}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1307}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1328}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 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\Common.cs (4)
441internal static TaskCreationOptions GetCreationOptionsForTask(bool isReplacementReplica = false) 443TaskCreationOptions options = TaskCreationOptions.DenyChildAttach; 444if (isReplacementReplica) options |= TaskCreationOptions.PreferFairness;
Internal\SourceCore.cs (1)
36private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Threading.Tasks.Parallel (4)
System\Threading\Tasks\Parallel.cs (2)
337tasks[i] = Task.Factory.StartNew(actionsCopy[i], parallelOptions.CancellationToken, TaskCreationOptions.None, 340tasks[0] = new Task(actionsCopy[0], parallelOptions.CancellationToken, TaskCreationOptions.None);
System\Threading\Tasks\Parallel.ForEachAsync.cs (1)
581Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
System\Threading\Tasks\TaskReplicator.cs (1)
80_pendingTask = new Task(s => ((Replica)s!).Execute(), this, CancellationToken.None, TaskCreationOptions.None);
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 (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
468System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
VBCSCompiler (1)
src\Compilers\Server\VBCSCompiler\ClientConnectionHandler.cs (1)
172var task = new Task<BuildResponse>(func, cancellationToken, TaskCreationOptions.LongRunning);