87 writes to CancellationToken
Aspire.Hosting (2)
ApplicationModel\ResourceCommandService.cs (2)
370CancellationToken = cancellationToken, 444CancellationToken = linkedCts.Token,
Aspire.Hosting.Azure.Tests (64)
AzureEnvironmentResourceExtensionsTests.cs (64)
111CancellationToken = cts.Token, 183CancellationToken = CancellationToken.None, 308CancellationToken = cts.Token, 656CancellationToken = CancellationToken.None, 710CancellationToken = CancellationToken.None, 1070CancellationToken = CancellationToken.None, 1151CancellationToken = CancellationToken.None, 1235CancellationToken = CancellationToken.None, 1504CancellationToken = CancellationToken.None, 1568CancellationToken = CancellationToken.None, 1629CancellationToken = CancellationToken.None, 1690CancellationToken = CancellationToken.None, 1825CancellationToken = CancellationToken.None, 1883CancellationToken = CancellationToken.None, 1934CancellationToken = CancellationToken.None, 1946CancellationToken = CancellationToken.None, 2030CancellationToken = CancellationToken.None, 2114CancellationToken = CancellationToken.None, 2208CancellationToken = CancellationToken.None, 2279CancellationToken = CancellationToken.None, 2357CancellationToken = CancellationToken.None, 2371CancellationToken = CancellationToken.None, 2436CancellationToken = CancellationToken.None, 2500CancellationToken = CancellationToken.None, 2554CancellationToken = CancellationToken.None, 2614CancellationToken = CancellationToken.None, 2691CancellationToken = CancellationToken.None, 2705CancellationToken = CancellationToken.None, 2768CancellationToken = CancellationToken.None, 2785CancellationToken = CancellationToken.None, 2866CancellationToken = CancellationToken.None, 2912CancellationToken = CancellationToken.None, 2965CancellationToken = CancellationToken.None, 2979CancellationToken = CancellationToken.None, 3032CancellationToken = CancellationToken.None, 3105CancellationToken = CancellationToken.None, 3158CancellationToken = CancellationToken.None, 3218CancellationToken = CancellationToken.None, 3279CancellationToken = CancellationToken.None, 3349CancellationToken = CancellationToken.None, 3410CancellationToken = CancellationToken.None, 3479CancellationToken = CancellationToken.None, 3536CancellationToken = CancellationToken.None, 3599CancellationToken = CancellationToken.None, 3670CancellationToken = CancellationToken.None, 3725CancellationToken = CancellationToken.None, 3765CancellationToken = CancellationToken.None, 3839CancellationToken = CancellationToken.None, 3887CancellationToken = CancellationToken.None, 3943CancellationToken = CancellationToken.None, 4090CancellationToken = CancellationToken.None, 4169CancellationToken = CancellationToken.None, 4241CancellationToken = CancellationToken.None, 4321CancellationToken = CancellationToken.None, 4395CancellationToken = CancellationToken.None, 4447CancellationToken = CancellationToken.None, 4493CancellationToken = CancellationToken.None, 4539CancellationToken = CancellationToken.None, 4607CancellationToken = cts.Token, 4846CancellationToken = CancellationToken.None, 4898CancellationToken = CancellationToken.None, 4945CancellationToken = CancellationToken.None, 4993CancellationToken = CancellationToken.None, 5131CancellationToken = CancellationToken.None,
Aspire.Hosting.Blazor.Tests (2)
BlazorHostedExtensionsTests.cs (1)
326CancellationToken = CancellationToken.None,
WithBlazorAppTests.cs (1)
324CancellationToken = CancellationToken.None,
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
576CancellationToken = CancellationToken.None, 628CancellationToken = CancellationToken.None, 676CancellationToken = CancellationToken.None,
Aspire.Hosting.Foundry.Tests (1)
PromptAgentTests.cs (1)
191CancellationToken = cts.Token,
Aspire.Hosting.Maui.Tests (1)
MauiBuildQueueTests.cs (1)
1154CancellationToken = CancellationToken.None,
Aspire.Hosting.MongoDB.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
Aspire.Hosting.MySql.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
Aspire.Hosting.PostgreSQL.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
Aspire.Hosting.Redis.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
Aspire.Hosting.SqlServer.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
Aspire.Hosting.Tests (1)
ResourceCommandAnnotationTests.cs (1)
202CancellationToken = commandCancellation.Token,
Aspire.Hosting.TestUtilities (1)
Utils\TerminalCommandTestHelpers.cs (1)
26CancellationToken = cancellationToken,
Aspire.Hosting.Valkey.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
87CancellationToken = TestContext.Current.CancellationToken, 110CancellationToken = cancellation.Token,
132 references to CancellationToken
Aspire.Hosting (14)
ApplicationModel\CommandOptions.cs (1)
137/// <see cref="ExecuteCommandContext.CancellationToken"/>.
ApplicationModel\CommandsConfigurationExtensions.cs (3)
33await orchestrator.StartResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 66await orchestrator.StopResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 409return context.CancellationToken;
Orchestrator\ParameterProcessor.cs (2)
374executeCommand: context => SetParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken), 410executeCommand: context => DeleteParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken),
ResourceBuilderExtensions.cs (8)
3664var processResult = await pendingProcessResult.WaitAsync(context.CancellationToken).ConfigureAwait(false); 3667catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested) 3841CancellationToken = context.CancellationToken, 4103CancellationToken = context.CancellationToken, 4113response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false); 4121CancellationToken = context.CancellationToken, 4129return await GetDefaultHttpCommandResultAsync(response, commandOptions, context.CancellationToken).ConfigureAwait(false); 4131catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested)
Aspire.Hosting.Azure (19)
AzureProvisioningController.cs (19)
761() => RunOperationAsync<bool>(model, new ResetStateIntent(ReprovisionAfterReset: true), context.CancellationToken), 763() => CreateEnvironmentCommandResultDataAsync(ResetProvisioningStateCommandName, model, context.CancellationToken), 774() => ChangeAzureContextCommandAsync(model, context.Arguments, context.CancellationToken), 776() => CreateEnvironmentCommandResultDataAsync(ChangeAzureContextCommandName, model, context.CancellationToken), 787() => ReprovisionAllAsync(model, context.CancellationToken), 789() => CreateEnvironmentCommandResultDataAsync(ReprovisionAllCommandName, model, context.CancellationToken), 800() => RunOperationAsync<DeleteAzureResourcesResult>(model, new DeleteAzureResourcesIntent(), context.CancellationToken), 806result => CreateDeleteAzureResourcesCommandResultDataAsync(model, result, context.CancellationToken)); 817() => ChangeResourceLocationCommandAsync(model, resourceName, context.Arguments, context.CancellationToken), 819() => CreateResourceCommandResultDataAsync(ChangeResourceLocationCommandName, model, resourceName, context.CancellationToken), 833() => CreateAzureResourceInfoCommandResultDataAsync(model, resourceName, context.CancellationToken)); 844() => CancelResourceAsync(model, resourceName, context.CancellationToken), 846() => CreateResourceCommandResultDataAsync(CancelCommandName, model, resourceName, context.CancellationToken)); 857() => RunOperationAsync<DeleteAzureResourceResult>(model, new DeleteAzureResourceIntent(resourceName), context.CancellationToken), 859result => CreateDeleteAzureResourceCommandResultDataAsync(model, resourceName, result, context.CancellationToken)); 870() => ForgetResourceStateAsync(model, resourceName, context.CancellationToken), 872() => CreateResourceCommandResultDataAsync(ForgetStateCommandName, model, resourceName, context.CancellationToken)); 883() => ReprovisionResourceAsync(model, resourceName, context.CancellationToken), 885() => CreateResourceCommandResultDataAsync(ReprovisionResourceCommandName, model, resourceName, context.CancellationToken),
Aspire.Hosting.Azure.Kusto (3)
AzureKustoBuilderExtensions.cs (3)
384.GetValueAsync(context.CancellationToken) 399.GetValueAsync(context.CancellationToken) 423context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Blazor (4)
BrowserDebuggerHelper.cs (4)
139await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false); 176await orchestrator.StartResourceAsync(dcpInstanceName, context.CancellationToken).ConfigureAwait(false); 236await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false); 246await orchestrator.StopResourceAsync(dcpInstanceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Browsers (3)
BrowserLogsBuilderExtensions.cs (3)
163await sessionManager.StartSessionAsync(browserLogsResource, currentConfiguration, context.ResourceName, url, context.CancellationToken).ConfigureAwait(false); 206return await configurationManager.ConfigureAsync(browserLogsResource, context.Arguments, context.CancellationToken).ConfigureAwait(false); 240var result = await sessionManager.CaptureScreenshotAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Browsers.Tests (3)
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (3)
163await sessionManager.StartSessionAsync(browserLogsResource, currentConfiguration, context.ResourceName, url, context.CancellationToken).ConfigureAwait(false); 206return await configurationManager.ConfigureAsync(browserLogsResource, context.Arguments, context.CancellationToken).ConfigureAwait(false); 240var result = await sessionManager.CaptureScreenshotAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
876context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore (10)
EFResourceBuilderExtensions.cs (10)
517.BuildAsync(executionContext, context.Logger, context.CancellationToken).ConfigureAwait(false); 546context.CancellationToken).ConfigureAwait(false); 591process.StandardOutput, resourceLogger, isErrorOutput: false, captureBuilder: null, context.CancellationToken); 593process.StandardError, resourceLogger, isErrorOutput: true, captureBuilder: stderrBuilder, context.CancellationToken); 596await process.WaitForExitAsync(context.CancellationToken).ConfigureAwait(false); 936await resourceNotificationService.WaitForDependenciesAsync(migrationResource, context.CancellationToken).ConfigureAwait(false); 946context.CancellationToken, 1023cancellationToken: context.CancellationToken).ConfigureAwait(false); 1065cancellationToken: context.CancellationToken).ConfigureAwait(false); 1104cancellationToken: context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore.Tests (1)
TestServices\TestEfTool.cs (1)
32context.CancellationToken);
Aspire.Hosting.Foundry (4)
PromptAgent\PromptAgentBuilderExtensions.cs (4)
84var endpoint = await agent.Project.Endpoint.GetValueAsync(ctx.CancellationToken).ConfigureAwait(false); 92ctx.CancellationToken.ThrowIfCancellationRequested(); 97var response = await responseClient.CreateResponseAsync(message, cancellationToken: ctx.CancellationToken).ConfigureAwait(false); 101catch (OperationCanceledException) when (ctx.CancellationToken.IsCancellationRequested)
Aspire.Hosting.Maui.Tests (3)
MauiBuildQueueTests.cs (3)
806await stopCompletion.Task.WaitAsync(context.CancellationToken); 845await Task.Delay(Timeout.InfiniteTimeSpan, context.CancellationToken); 983await Task.Delay(Timeout.InfiniteTimeSpan, context.CancellationToken);
Aspire.Hosting.MongoDB (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Aspire.Hosting.MySql (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Aspire.Hosting.PostgreSQL (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Aspire.Hosting.Redis (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Aspire.Hosting.SqlServer (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Aspire.Hosting.Tests (3)
ResourceCommandServiceTests.cs (3)
1852await Task.Delay(Timeout.Infinite, e.CancellationToken); 1900await Task.Delay(Timeout.Infinite, e.CancellationToken); 1902catch (OperationCanceledException) when (e.CancellationToken.IsCancellationRequested)
Aspire.Hosting.Valkey (4)
src\Shared\ContainerReplCommand.cs (4)
26context.CancellationToken.ThrowIfCancellationRequested(); 42.ResolveAsync(context.CancellationToken).ConfigureAwait(false); 43var options = await createOptions(context.CancellationToken).ConfigureAwait(false); 45context.CancellationToken.ThrowIfCancellationRequested();
Stress.AppHost (29)
CommandResources.cs (2)
1187await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StopCommand, c.CancellationToken); 1196await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StartCommand, c.CancellationToken);
InteractionCommands.cs (27)
20var resultTask1 = interactionService.PromptConfirmationAsync("Command confirmation", "Are you sure?", cancellationToken: commandContext.CancellationToken); 21var resultTask2 = interactionService.PromptMessageBoxAsync("Command confirmation", "Are you really sure?", new MessageBoxInteractionOptions { Intent = MessageIntent.Warning, ShowSecondaryButton = true }, cancellationToken: commandContext.CancellationToken); 125cancellationToken: commandContext.CancellationToken); 175cancellationToken: commandContext.CancellationToken); 261cancellationToken: commandContext.CancellationToken); 355cancellationToken: commandContext.CancellationToken); 481cancellationToken: commandContext.CancellationToken); 581cancellationToken: commandContext.CancellationToken); 614cancellationToken: commandContext.CancellationToken); 622cancellationToken: commandContext.CancellationToken); 630cancellationToken: commandContext.CancellationToken); 640cancellationToken: commandContext.CancellationToken); 663cancellationToken: commandContext.CancellationToken); 854commandContext.CancellationToken); 891commandContext.CancellationToken); 918cancellationToken: commandContext.CancellationToken); 936using var cts = CancellationTokenSource.CreateLinkedTokenSource(commandContext.CancellationToken); 944await Task.Delay(10000, commandContext.CancellationToken); 970commandContext.CancellationToken); 993cancellationToken: commandContext.CancellationToken); 1018commandContext.CancellationToken); 1038commandContext.CancellationToken); 1056await Task.Delay(10000, commandContext.CancellationToken); 1085cancellationToken: commandContext.CancellationToken); 1100var content = await file.ReadAllBytesAsync(commandContext.CancellationToken); 1132cancellationToken: commandContext.CancellationToken); 1152var bytes = await file.ReadAllBytesAsync(commandContext.CancellationToken);
Terminals.AppHost (11)
TerminalInteractionCommands.cs (11)
67cancellationToken: commandContext.CancellationToken); 146cancellationToken: commandContext.CancellationToken); 190await terminal.SendTextAsync("echo aspire-dock-ready\r", commandContext.CancellationToken); 191await terminal.WaitForTextAsync("aspire-dock-ready", TimeSpan.FromSeconds(10), commandContext.CancellationToken); 306cancellationToken: commandContext.CancellationToken); 349commandContext.CancellationToken); 356catch (OperationCanceledException) when (commandContext.CancellationToken.IsCancellationRequested) 375cancellationToken: commandContext.CancellationToken); 423await terminal.SendTextAsync($"echo apphost-was-here-{marker}\n", commandContext.CancellationToken); 424await terminal.WaitForTextAsync($"apphost-was-here-{marker}\r\n", TimeSpan.FromSeconds(15), commandContext.CancellationToken); 434cancellationToken: commandContext.CancellationToken);