599 references to RunContinuationsAsynchronously
aspire (17)
Backchannel\AppHostCliBackchannel.cs (2)
41private TaskCompletionSource _disconnectTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 322_disconnectTaskCompletionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
636var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\ExtensionBackchannel.cs (2)
108_connectionSetupTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 136_connectionSetupTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\ResourceSnapshotWatcher.cs (1)
17private readonly TaskCompletionSource _initialLoadTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\BaseCommand.cs (1)
146var stoppingMessageTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\DashboardRunCommand.cs (1)
378var readyTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConsoleCancellationManager.cs (1)
88private readonly TaskCompletionSource<int> _processTerminationCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
DotNet\ProcessExecution.cs (1)
40private readonly TaskCompletionSource _startCompletion = new(TaskCreationOptions.RunContinuationsAsynchronously);
Interaction\ExtensionInteractionService.cs (1)
67var completionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Processes\IsolatedProcess.cs (3)
117private readonly TaskCompletionSource _startCompletion = new(TaskCreationOptions.RunContinuationsAsynchronously); 200var outputTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 219var errorTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Processes\WindowsProcessInterop.cs (1)
700var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\AppHostInfoResolver.cs (1)
66var completion = new TaskCompletionSource<AppHostProjectInfo>(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\AppHostServerSession.cs (1)
178var completion = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Cli.Tests (130)
Agents\AspireSkillsInstallerTests.cs (5)
89var cleanupRetryBudgetExceeded = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 700var retryObserved = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 906var retryObserved = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 980var verificationStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 981var verificationGate = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\ExtensionBackchannelTests.cs (7)
29var setupEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 30var releaseSetup = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 65var setupEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 66var releaseSetup = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 105var firstSetupEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 106var takeoverSetupEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 107var releaseTakeoverSetup = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\AppHostLauncherTests.cs (7)
162var childExitTask = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously).Task; 178var readiness = new TaskCompletionSource<WaitForAppHostReadyResponse?>(TaskCreationOptions.RunContinuationsAsynchronously); 445var connectionLostStatusDisplayed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 496var childExitTask = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously).Task; 522var childExitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1278public TaskCompletionSource Started { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 1534private readonly TaskCompletionSource<int> _exit = new(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\BaseCommandTests.cs (1)
425var handlerEnteredTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\DashboardRunCommandTests.cs (5)
173var releaseBundle = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 174var bundleStatusDisplayed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 393var readyTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 394var stoppingMessageDisplayedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 395var shutdownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\DescribeCommandTests.cs (1)
725var waitForCancellation = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\DoCommandTests.cs (1)
679var appHostExit = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\InstallationInfoOutputTests.cs (2)
18var discoveryStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 19var discoveryExited = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\LogsCommandTests.cs (3)
1432var allowFollowLogsTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1433var allowExitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1701var waitForCancellation = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\LsCommandTests.cs (5)
417var candidateReported = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 418var allowDiscoveryToComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 606var statusRefreshed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 607var allowDiscoveryToComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 608var candidateReported = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\NewCommandTests.cs (2)
1616var extractionStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1617var allowExtraction = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\PublishCommandPromptingIntegrationTests.cs (1)
1035var completionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\RunCommandTests.cs (28)
310var runCancellationObserved = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 370var buildCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 433var runCancellationObserved = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 434var buildCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 534var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var dashboardCanReturn = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var appHostReady = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var appHostCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 639var startupReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 640var teardownStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 641var teardownCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 646var teardownCanFinish = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1337var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1338var appHostCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1413var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1414var appHostCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1477var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1585var runCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1647var runCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1720var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1777var connectingToAppHost = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1844var runCanExit = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1906var dashboardRequested = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1907var logCaptureStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1908var logCaptureCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2859var displayLinesStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2860var allowDisplayLinesToComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3630var tcs = new TaskCompletionSource<Dictionary<string, string>>(TaskCreationOptions.RunContinuationsAsynchronously);
DotNet\DotNetCliRunnerTests.cs (8)
759ConnectAsyncCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously) 781var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously); 983var launchAppHostCalledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 986ConnectAsyncCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously) 1012var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously); 1066var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously); 1105var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously); 1147var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously);
DotNet\ProcessExecutionDetachedTests.cs (2)
602private readonly TaskCompletionSource _acquisitionStarted = new(TaskCreationOptions.RunContinuationsAsynchronously); 603private readonly TaskCompletionSource _allowAcquire = new(TaskCreationOptions.RunContinuationsAsynchronously);
DotNet\ProcessExecutionTests.cs (5)
47var firstLineSeen = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48var releaseCallback = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 107var firstLineSeen = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 108var releaseCallback = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 218var signaled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Interaction\ExtensionInteractionServiceTests.cs (1)
84var cancellationMessageCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Interaction\SpectreConsoleLoggerProviderTests.cs (3)
165var barrier = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 166var promptStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 266var scopeOpenedDuringFlush = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
NuGet\BundleNuGetServiceTests.cs (2)
318var firstRestoreStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 319var allowFirstRestoreToComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
NuGet\NuGetPackagePrefetcherTests.cs (9)
121var templateArrived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 122var cliArrived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 150var templateTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 151var cliTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 195var errorTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var templateEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 406var templateFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 407var cliEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 408var cliFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Processes\IsolatedProcessTests.cs (2)
121var callbackEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 122var releaseCallback = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Processes\LauncherLivenessMonitorTests.cs (1)
35var cancelTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Processes\ParentProcessLivenessMonitorTests.cs (3)
28var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 49var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 121var callbackInvokedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ProfileCaptureServiceTests.cs (2)
278var hangingExit = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 570var exitCompletionSource = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\AppHostInfoResolverTests.cs (4)
110var started = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 111var complete = new TaskCompletionSource<(int ExitCode, JsonDocument? Output)>(TaskCreationOptions.RunContinuationsAsynchronously); 141var started = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 142var complete = new TaskCompletionSource<(int ExitCode, JsonDocument? Output)>(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\AppHostServerSessionTests.cs (1)
271var signaled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\GuestAppHostProjectTests.cs (2)
1091var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously); 1115var backchannelCompletionSource = new TaskCompletionSource<IAppHostCliBackchannel>(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\ProcessGuestLauncherTests.cs (2)
152var signalerNeverCompletes = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 214var signaled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Projects\ProjectLocatorTests.cs (3)
316var startGate = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3173var slowValidationStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3174var slowValidationCanceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Telemetry\InternalMicrosoftDetectorTests.cs (5)
131var slowProbeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 132var slowProbeCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 175var faultingProbeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 515var allCandidatesEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 516var releaseCandidates = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TestServices\TestAppHostCliBackchannel.cs (1)
26public TaskCompletionSource DisconnectCompletionSource { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
Utils\EnvironmentCheckerTests.cs (4)
17var checkStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 18var checkExited = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 70var blockedCheck = new TaskCompletionSource<IReadOnlyList<EnvironmentCheckResult>>(TaskCreationOptions.RunContinuationsAsynchronously); 96var blockedCheck = new TaskCompletionSource<IReadOnlyList<EnvironmentCheckResult>>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard (10)
Components\Interactions\InteractionsProvider.cs (2)
48private TaskCompletionSource _interactionAvailableTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 644_interactionAvailableTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Components\Pages\Resources.razor.cs (2)
108private readonly TaskCompletionSource _loadingTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 639_contextMenuClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ServiceClient\DashboardClient.cs (6)
57private TaskCompletionSource _whenConnectedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 58private TaskCompletionSource _initialDataReceivedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 61private readonly TaskCompletionSource _resourceWatchCompleteTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 62private readonly TaskCompletionSource _interactionWatchCompleteTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 296_whenConnectedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 301_initialDataReceivedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Components.Tests (15)
Layout\MainLayoutTests.cs (4)
36var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 58var dismissedSettingSetTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 99var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 151var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\ConsoleLogsTests.cs (6)
61var targetLocationTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 333var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 448var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 497var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 668var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 732var 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)
942var connectionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Tests (27)
Integration\OtlpGrpcServiceTests.cs (1)
199var tcs = new TaskCompletionSource<DashboardOptions>(TaskCreationOptions.RunContinuationsAsynchronously);
Model\DashboardClientTests.cs (3)
383var disconnectedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 410var unsupportedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 462var connectedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Model\DashboardCommandExecutorTests.cs (6)
26var commandStartedTcs = new TaskCompletionSource<CancellationToken>(TaskCreationOptions.RunContinuationsAsynchronously); 27var finishCommandTcs = new TaskCompletionSource<ResourceCommandResponseViewModel>(TaskCreationOptions.RunContinuationsAsynchronously); 73var commandStartedTcs = new TaskCompletionSource<CancellationToken>(TaskCreationOptions.RunContinuationsAsynchronously); 74var finishCommandTcs = new TaskCompletionSource<ResourceCommandResponseViewModel>(TaskCreationOptions.RunContinuationsAsynchronously); 114var commandStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var finishCommandTcs = new TaskCompletionSource<ResourceCommandResponseViewModel>(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceOutgoingPeerResolverTests.cs (1)
277var 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 (10)
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); 973var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1064var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1147var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1250var firstLogReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1347var firstSpanReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting (16)
ApplicationModel\ResourceLoggerService.cs (1)
380private readonly TaskCompletionSource _logStreamCompletion = new(TaskCreationOptions.RunContinuationsAsynchronously);
ApplicationModel\ValueSnapshot.cs (1)
21new(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\AppHostStartupState.cs (1)
10private readonly TaskCompletionSource _ready = new(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\AuxiliaryBackchannelService.cs (1)
27private readonly TaskCompletionSource _listeningTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\AppResource.cs (1)
41_initializedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\DcpExecutor.cs (1)
128_containerContextSource = new TaskCompletionSource<ContainerCreationContext>(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\DcpResourceWatcher.cs (1)
1019private readonly TaskCompletionSource _completion = new(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\Process\ProcessUtil.cs (2)
83var stdoutComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var stderrComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Health\ResourceHealthCheckService.cs (1)
377_delayInterruptTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InteractionService.cs (1)
713public TaskCompletionSource<InteractionCompletionState> CompletionTcs { get; } = new TaskCompletionSource<InteractionCompletionState>(TaskCreationOptions.RunContinuationsAsynchronously);
Orchestrator\ParameterProcessor.cs (4)
58parameterResource.WaitForValueTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 478var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 504parameterResource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 580var allParametersResolved = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Pipelines\DistributedApplicationPipeline.cs (1)
859stepCompletions[step.Name] = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure (6)
AzureBicepResource.cs (1)
46ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
AzureEnvironmentResource.cs (1)
63internal TaskCompletionSource<ProvisioningContext> ProvisioningContextTask { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
AzureProvisioningController.cs (2)
1053resource.AzureResource.ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 1405new(TaskCreationOptions.RunContinuationsAsynchronously),
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (2)
83var stdoutComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var stderrComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure.Kubernetes (2)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (2)
83var stdoutComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var stderrComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure.Kusto.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure.Tests (22)
AzureBicepProvisionerTests.cs (1)
552var allLookupsStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
AzureEnvironmentResourceExtensionsTests.cs (16)
514var existingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2337var completion = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 5586public TaskCompletionSource FirstProvisionStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5587public TaskCompletionSource AllowFirstProvisionToComplete { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5625public TaskCompletionSource FirstProvisionStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5626public TaskCompletionSource OperationCancellationRequested { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5627public TaskCompletionSource AllowFirstProvisionToComplete { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5646public TaskCompletionSource FirstProvisionStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5647public TaskCompletionSource AllowFirstProvisionToThrow { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5677public TaskCompletionSource FirstProvisionStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5679public TaskCompletionSource OperationCancellationRequested { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5681public TaskCompletionSource AllowFirstProvisionToComplete { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5748public TaskCompletionSource ChildProvisionStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5750public TaskCompletionSource AllowChildProvisionToComplete { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5889public TaskCompletionSource DeleteStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 5890public TaskCompletionSource AllowDeleteToComplete { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
AzureSignalREmulatorFunctionalTest.cs (1)
111var messageTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
DefaultArmClientProviderTests.cs (4)
344private readonly TaskCompletionSource _nestedDeploymentOperationRequestsStarted = new(TaskCreationOptions.RunContinuationsAsynchronously); 345private readonly TaskCompletionSource _keyVaultDeletePollStarted = new(TaskCreationOptions.RunContinuationsAsynchronously); 346private readonly TaskCompletionSource _deletedKeyVaultPurgePollStarted = new(TaskCreationOptions.RunContinuationsAsynchronously); 803=> new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Blazor.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Browsers (5)
BrowserHost.cs (1)
254private readonly TaskCompletionSource _terminationSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserHostRegistry.cs (1)
279_lockUsersDrained = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserLogsCdpConnection.cs (1)
359private readonly TaskCompletionSource<TResult> _taskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserLogsCdpConnectionMultiplexer.cs (1)
219private readonly TaskCompletionSource _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserPageSession.cs (1)
27private readonly TaskCompletionSource<BrowserPageSessionResult> _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Browsers.Tests (24)
BrowserHostTests.cs (1)
101private readonly TaskCompletionSource<BrowserLogsProcessResult> _processCompletion = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserLogsBuilderExtensionsTests.cs (5)
1859private readonly TaskCompletionSource<(int ExitCode, Exception? Error)> _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 1882private TaskCompletionSource<object?> CompletionObserverStartedSource { get; set; } = new(TaskCreationOptions.RunContinuationsAsynchronously); 1910CompletionObserverStartedSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 1911_completionObserverGate = new(TaskCreationOptions.RunContinuationsAsynchronously); 1929var source = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserLogsCdpConnectionTests.cs (3)
40var routedEventSource = new TaskCompletionSource<BrowserLogsCdpProtocolEvent>(TaskCreationOptions.RunContinuationsAsynchronously); 156var routedEventSource = new TaskCompletionSource<BrowserLogsCdpProtocolEvent>(TaskCreationOptions.RunContinuationsAsynchronously); 408private readonly TaskCompletionSource _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserLogsRunningSessionTests.cs (3)
80var completed = new TaskCompletionSource<(int? ExitCode, Exception? Error)>(TaskCreationOptions.RunContinuationsAsynchronously); 105private readonly TaskCompletionSource _terminationSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 153private readonly TaskCompletionSource<BrowserPageSessionResult> _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
BrowserPageSessionTests.cs (4)
347private readonly TaskCompletionSource _terminationSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 386private readonly TaskCompletionSource _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 387private readonly TaskCompletionSource _instrumentationEnabled = new(TaskCreationOptions.RunContinuationsAsynchronously); 400public TaskCompletionSource ScreenshotCaptureStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
ConsoleLoggingTestHelpers.cs (1)
15var subscribedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Aspire.Hosting.Browsers\BrowserHost.cs (1)
254private readonly TaskCompletionSource _terminationSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\Aspire.Hosting.Browsers\BrowserHostRegistry.cs (1)
279_lockUsersDrained = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (1)
359private readonly TaskCompletionSource<TResult> _taskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\Aspire.Hosting.Browsers\BrowserLogsCdpConnectionMultiplexer.cs (1)
219private readonly TaskCompletionSource _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\Aspire.Hosting.Browsers\BrowserPageSession.cs (1)
27private readonly TaskCompletionSource<BrowserPageSessionResult> _completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Containers.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.DevTunnels.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Docker (2)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (2)
83var stdoutComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var stderrComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Dotnet.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.DotnetTool.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Foundry (1)
FoundryLocalService.cs (1)
130var endpointSource = new TaskCompletionSource<Uri>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Foundry.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.GitHub.Models.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.JavaScript.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Kafka.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Maui.Tests (2)
MauiBuildQueueTests.cs (2)
892return _buildCompletions.GetOrAdd(name, _ => new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 897return _buildStarted.GetOrAdd(name, _ => new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously));
Aspire.Hosting.MySql.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.OpenAI.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.PostgreSQL.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
236var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.RabbitMQ.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.RemoteHost.Tests (5)
OrphanDetectorTests.cs (5)
37var stopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 62var stopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 87var stopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 112var stopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 138var stopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Sdk.Tests (1)
AppHostSdkTargetsTests.cs (1)
865var terminationRequested = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Testing (4)
DistributedApplicationFactory.cs (4)
24private readonly TaskCompletionSource _startedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 25private readonly TaskCompletionSource _exitTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 26private readonly TaskCompletionSource<DistributedApplicationBuilder> _builderTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 27private readonly TaskCompletionSource<DistributedApplication> _appTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Testing.Tests (3)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
12var subscribedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (117)
AppHostSmokeTests.cs (1)
55var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (15)
396passwordParameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 443topLevelParameter.Resource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 445referencedParameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 491secretA.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 495secretB.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 573secretA.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 577secretB.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 648secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 685secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 719secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 753secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 815secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 876coldSecret.Resource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1026secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1077var waitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Cli\CliOrphanDetectorTests.cs (8)
40var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 67var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 93var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 120var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 215var stopSignalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 267var resourcesCreatedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Dashboard\ResourcePublisherTests.cs (1)
55var tcs = new TaskCompletionSource<IReadOnlyList<ResourceSnapshotChange>>(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\DcpExecutorTests.cs (18)
1581var followStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1598var terminalNotification = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1657var runningFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1658var failedToStartSnapshotStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1659var failedToStartFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1757var terminalLogCountAtNotification = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 1815var normalStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1845var otherTerminalNotification = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1914var runningFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1915var terminalFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2088var secondFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2648var previousBatchReady = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2649var releasePreviousBatch = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2650var replacementFollowStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2934var normalStreamStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3906var subscriberEntered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3907var releaseSubscriber = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4043var tcs = new TaskCompletionSource<OnResourceFailedToStartContext>(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\GatedLogger.cs (2)
10private readonly TaskCompletionSource _blocked = new(TaskCreationOptions.RunContinuationsAsynchronously); 11private readonly TaskCompletionSource _release = new(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\GatedReadStream.cs (2)
10private readonly TaskCompletionSource _readStarted = new(TaskCreationOptions.RunContinuationsAsynchronously); 11private readonly TaskCompletionSource<ReadOnlyMemory<byte>> _content = new(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\ProcessUtilTests.cs (2)
17var callbackStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 18var releaseCallback = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
DistributedApplicationTests.cs (2)
328var resourcesCreatedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 739var tcs = new TaskCompletionSource<DistributedApplicationModel>(TaskCreationOptions.RunContinuationsAsynchronously);
Eventing\DistributedApplicationBuilderEventingTests.cs (2)
180var beforeResourceStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 342var 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 (4)
896var updateTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 949var updateTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1189var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1223var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Orchestrator\ApplicationOrchestratorTests.cs (10)
602var blockerReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 638var dependencyReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 680var dependencyReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 740var dependencyReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 789var dependencyReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 842var dependencyReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 912var blockerReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 953var blockerReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1016var referencedReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1049var blockerReleased = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Orchestrator\ParameterProcessorTests.cs (13)
195param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 280var notificationDismissed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 388parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 440param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 484secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 517param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 556param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1096parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1113parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1223secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1406connectionStringParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1447regularParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1491customParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Pipelines\DistributedApplicationPipelineTests.cs (3)
782var failingStepStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 813var failingStepCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 845var failingStepCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceCommandServiceTests.cs (2)
1732var commandStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1777var commandStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceLoggerServiceTests.cs (6)
386var subscribeRegistered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 387var continueBacklogDelivery = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 509var start = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 552var start = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 599var start = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 743var watchStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
12var subscribedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WithProcessCommandTests.cs (1)
1458var pendingProcessResult = new TaskCompletionSource<ProcessResult>(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); 691var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 719var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 747var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 809var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 841var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 889var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 919var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.TestUtilities (1)
Utils\TestProcessRunner.cs (1)
37public TaskCompletionSource<ProcessSpec> RunStarted { get; } = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Valkey.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Managed.Tests (1)
ParentProcessWatchdogTests.cs (1)
69var exitCode = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Playground.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
67private readonly TaskCompletionSource _connectedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.TerminalHost.Tests (2)
tests\Shared\AsyncTestHelpers.cs (2)
243var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 263var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
dotnet (2)
Commands\Test\MTP\TestApplication.cs (1)
678var completion = new TaskCompletionSource<IResponse>(TaskCreationOptions.RunContinuationsAsynchronously);
Commands\Test\MTP\TestRunPolicy.cs (1)
25new(TaskCreationOptions.RunContinuationsAsynchronously);
GenerateDocumentationAndConfigFiles (1)
src\roslyn\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);
Microsoft.AspNetCore.Components (2)
Routing\Router.cs (2)
352var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 363var cancellationTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.AI (1)
Blocks\UIActionBlock.cs (1)
27new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Endpoints (3)
CacheView\CacheViewService.cs (3)
109var resolution = new TaskCompletionSource<SerializedRenderFragment?>(TaskCreationOptions.RunContinuationsAsynchronously); 276var captureCompletion = new TaskCompletionSource<SerializedRenderFragment>(TaskCreationOptions.RunContinuationsAsynchronously); 277var factoryStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Testing (3)
Infrastructure\ServerFactory.cs (1)
185var readyTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Infrastructure\TestLockProvider.cs (2)
38_ => new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 52_ => new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously));
Microsoft.AspNetCore.Components.Web (1)
Virtualization\Virtualize.cs (1)
332var renderCommitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.WebView.WindowsForms (2)
WindowsFormsDispatcher.cs (2)
80 var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 148 var tcs = new TaskCompletionSource<TResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Connections (2)
Internal\HttpConnectionContext.cs (1)
73private readonly TaskCompletionSource _disposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\HttpConnectionDispatcher.cs (1)
359var currentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation (1)
RuntimeViewCompiler.cs (1)
144taskSource = new TaskCompletionSource<CompiledViewDescriptor>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.TagHelpers (2)
Cache\DistributedCacheTagHelperService.cs (1)
77var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
CacheTagHelper.cs (1)
97var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Testing (1)
DeferredHostBuilder.cs (1)
22private readonly TaskCompletionSource _hostStartTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching (2)
DispatcherExtensions.cs (2)
24var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously); 63var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Routing (1)
EndpointRoutingMiddleware.cs (1)
292var 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\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpServer.cs (1)
34private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IntegrationTesting (1)
src\aspnetcore\src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core (8)
Internal\ConnectionDispatcher.cs (1)
15private readonly TaskCompletionSource _acceptLoopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Http3\Http3Stream.cs (1)
201abortCompleted = _abortCompletedTcs = 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\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.DirectTls (1)
TlsEventPump.cs (1)
63private readonly TaskCompletionSource _exitSignal = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
42_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
2542_stopTcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\InvocationRequest.cs (1)
176private readonly TaskCompletionSource<object?> _completionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
258var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Core (3)
HubConnectionContext.cs (1)
31private readonly TaskCompletionSource _abortCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
258var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
Internal\AckHandler.cs (1)
92Tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.AspNetCore.TestHost (1)
HttpContextBuilder.cs (1)
16private readonly TaskCompletionSource<HttpContext> _responseTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis (6)
DiagnosticAnalyzer\AsyncQueue.cs (6)
24private readonly TaskCompletionSource<bool> _whenCompleted = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 102Debug.Assert(waiter.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 200Debug.Assert(tcs.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 205Debug.Assert(_whenCompleted.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 281var waiter = new TaskCompletionSource<Optional<TElement>>(TaskCreationOptions.RunContinuationsAsynchronously); 316Debug.Assert(taskCompletionSource.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously));
Microsoft.CodeAnalysis.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.Workspaces (2)
Shared\TestHooks\AsynchronousOperationListener.cs (1)
174var source = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
Rpc\RpcClient.cs (1)
144var requestCompletionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Diagnostics.NETCore.Client (1)
HandleableCollection.cs (1)
176TaskCompletionSource<T> completionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.DotNet.HotReload.Watch (4)
FileWatcher\FileWatcher.cs (1)
182var fileChangedSource = new TaskCompletionSource<ChangedPath?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\AbstractBrowserRefreshServer.cs (1)
36private readonly TaskCompletionSource<None> _browserConnected = new(TaskCreationOptions.RunContinuationsAsynchronously);
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\BrowserConnection.cs (1)
20public readonly TaskCompletionSource<None> Disconnected = new(TaskCreationOptions.RunContinuationsAsynchronously);
UI\ConsoleInputReader.cs (1)
24var tcs = new TaskCompletionSource<ConsoleKeyInfo>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.AI.Tests (1)
ChatRouting\OrderedFailoverChatClientTests.cs (1)
156var allStarted = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.AsyncState.Tests (8)
AsyncStateTests.cs (8)
47var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 48var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 49var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 97var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 98var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 99var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 148var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 180var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Hybrid (2)
Internal\DefaultHybridCache.StampedeStateT.cs (2)
36_result = new(TaskCreationOptions.RunContinuationsAsynchronously); 90var cancelStub = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Diagnostics.Testing (3)
Logging\FakeLogCollector.cs (1)
156_logEnumerationSharedWaiter = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Logging\FakeLogCollector.LogEnumeration.cs (1)
16new(TaskCreationOptions.RunContinuationsAsynchronously);
parent\parent\parent\eng\MSBuild\parent\parent\src\LegacySupport\TaskWaitAsync\TaskExtensions.cs (1)
39var tcs = new TaskCompletionSource<TResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Diagnostics.Testing.Tests (1)
Logging\FakeLogCollectorTests.LogEnumeration.cs (1)
100var abcProcessedAB = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Hosting (1)
Internal\Host.cs (1)
397var tcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Hosting.WindowsServices (2)
WindowsServiceLifetime.cs (2)
20private readonly TaskCompletionSource<object?> _delayStart = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 21private readonly TaskCompletionSource<object?> _serviceDispatcherStopped = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Http.Diagnostics (1)
parent\parent\parent\eng\MSBuild\parent\parent\src\LegacySupport\TaskWaitAsync\TaskExtensions.cs (1)
39var tcs = new TaskCompletionSource<TResult>(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.ML.Core (1)
Utilities\ThreadUtils.cs (1)
61var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
MSBuild (1)
OutOfProcTaskHostNode.cs (1)
1029var tcs = new TaskCompletionSource<INodePacket>(TaskCreationOptions.RunContinuationsAsynchronously);
NuGet.Protocol (2)
Plugins\OutboundRequestContext`1.cs (1)
106_taskCompletionSource = new TaskCompletionSource<TResult?>(TaskCreationOptions.RunContinuationsAsynchronously);
Plugins\RequestHandlers\SymmetricHandshake.cs (1)
75_responseSentTaskCompletionSource = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Roslyn.Diagnostics.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System.Diagnostics.Process (3)
Microsoft\Win32\SafeHandles\SafeProcessHandle.cs (2)
358TaskCompletionSource<bool> tcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 431TaskCompletionSource<bool> tcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Diagnostics\Process.cs (1)
1742var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
1084: base(TaskCreationOptions.RunContinuationsAsynchronously)
System.Net.Http (5)
src\runtime\src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
377_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1166: base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
133_expect100ContinueWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (1)
261_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Http.WinHttpHandler (2)
System\Net\Http\WinHttpRequestStream.cs (2)
226new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 247new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Quic (2)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
321_finalTaskSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Quic\QuicConnection.cs (1)
143private readonly TaskCompletionSource _connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Security (1)
System\Net\Security\SslStream.Protocol.cs (1)
1115_handshakeWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.WebSockets (1)
System\Net\WebSockets\AsyncMutex.cs (1)
249public Waiter(AsyncMutex owner) : base(TaskCreationOptions.RunContinuationsAsynchronously) => Owner = owner;
System.Private.CoreLib (7)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\SemaphoreSlim.cs (1)
72internal TaskNode() : base((object?)null, TaskCreationOptions.RunContinuationsAsynchronously) { }
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (4)
477if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 697TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 3624(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 6041thisRef.AtomicStateUpdate((int)TaskCreationOptions.RunContinuationsAsynchronously, 0);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (1)
207TaskCreationOptions.RunContinuationsAsynchronously)) != 0)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Timer.cs (1)
651var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.Runtime.InteropServices.JavaScript (2)
System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Task.cs (2)
55TaskCompletionSource tcs = new TaskCompletionSource(holder, TaskCreationOptions.RunContinuationsAsynchronously); 115TaskCompletionSource<T> tcs = new TaskCompletionSource<T>(holder, TaskCreationOptions.RunContinuationsAsynchronously);
System.ServiceModel.Http (1)
System\ServiceModel\Channels\MessageContent.cs (1)
31_writeCompletedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.ServiceModel.Primitives (8)
Internals\System\Runtime\ServiceModelSynchronizationContext.cs (1)
16Task.Factory.StartNew((s) => d(s), state, default, TaskCreationOptions.RunContinuationsAsynchronously, IOThreadScheduler.IOTaskScheduler);
Internals\System\Runtime\TimeoutHelper.cs (1)
313var tcs = new TaskCompletionSource<CancellationToken>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\CommunicationObject.cs (2)
327await Task.Factory.FromAsync(OnBeginClose, OnEndClose, timeout, TaskCreationOptions.RunContinuationsAsynchronously); 576await Task.Factory.FromAsync(OnBeginOpen, OnEndOpen, timeout, TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (1)
48_tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (1)
785_tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
System\ServiceModel\Channels\ServiceChannelProxy.cs (2)
213TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 318return new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
62_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\RendezvousChannel.cs (1)
53_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
45_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedChannel.cs (1)
39_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
44_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System.Threading.RateLimiting (5)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
422: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)
21private readonly TaskCompletionSource<object?> _disposeComplete = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
474: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
536: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
474: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (1)
1455base(TaskCreationOptions.RunContinuationsAsynchronously)
Blocks\BroadcastBlock.cs (1)
498private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Blocks\WriteOnceBlock.cs (2)
80_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 495Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
Internal\SourceCore.cs (1)
36private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Windows.Forms (6)
System\Windows\Forms\Control_InvokeAsync.cs (4)
64TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 189TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 290TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 395TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Windows\Forms\Form.cs (2)
5644TaskCreationOptions.RunContinuationsAsynchronously); 5944creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
TestingAppHost1.AppHost (3)
TestingAppHostEntryPointProbe.cs (3)
16var exited = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 49new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously));