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, 1095CancellationToken = CancellationToken.None, 1176CancellationToken = CancellationToken.None, 1260CancellationToken = CancellationToken.None, 1529CancellationToken = CancellationToken.None, 1593CancellationToken = CancellationToken.None, 1654CancellationToken = CancellationToken.None, 1715CancellationToken = CancellationToken.None, 1850CancellationToken = CancellationToken.None, 1908CancellationToken = CancellationToken.None, 1959CancellationToken = CancellationToken.None, 1971CancellationToken = CancellationToken.None, 2055CancellationToken = CancellationToken.None, 2139CancellationToken = CancellationToken.None, 2233CancellationToken = CancellationToken.None, 2304CancellationToken = CancellationToken.None, 2382CancellationToken = CancellationToken.None, 2396CancellationToken = CancellationToken.None, 2461CancellationToken = CancellationToken.None, 2525CancellationToken = CancellationToken.None, 2579CancellationToken = CancellationToken.None, 2639CancellationToken = CancellationToken.None, 2716CancellationToken = CancellationToken.None, 2730CancellationToken = CancellationToken.None, 2793CancellationToken = CancellationToken.None, 2810CancellationToken = CancellationToken.None, 2891CancellationToken = CancellationToken.None, 2937CancellationToken = CancellationToken.None, 2990CancellationToken = CancellationToken.None, 3004CancellationToken = CancellationToken.None, 3057CancellationToken = CancellationToken.None, 3130CancellationToken = CancellationToken.None, 3183CancellationToken = CancellationToken.None, 3243CancellationToken = CancellationToken.None, 3304CancellationToken = CancellationToken.None, 3374CancellationToken = CancellationToken.None, 3435CancellationToken = CancellationToken.None, 3504CancellationToken = CancellationToken.None, 3561CancellationToken = CancellationToken.None, 3624CancellationToken = CancellationToken.None, 3695CancellationToken = CancellationToken.None, 3750CancellationToken = CancellationToken.None, 3790CancellationToken = CancellationToken.None, 3864CancellationToken = CancellationToken.None, 3912CancellationToken = CancellationToken.None, 3968CancellationToken = CancellationToken.None, 4115CancellationToken = CancellationToken.None, 4194CancellationToken = CancellationToken.None, 4266CancellationToken = CancellationToken.None, 4346CancellationToken = CancellationToken.None, 4420CancellationToken = CancellationToken.None, 4472CancellationToken = CancellationToken.None, 4518CancellationToken = CancellationToken.None, 4564CancellationToken = CancellationToken.None, 4632CancellationToken = cts.Token, 4871CancellationToken = CancellationToken.None, 4923CancellationToken = CancellationToken.None, 4970CancellationToken = CancellationToken.None, 5018CancellationToken = CancellationToken.None, 5156CancellationToken = CancellationToken.None,
Aspire.Hosting.Blazor.Tests (2)
BlazorHostedExtensionsTests.cs (1)
307CancellationToken = CancellationToken.None,
WithBlazorAppTests.cs (1)
325CancellationToken = CancellationToken.None,
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
613CancellationToken = CancellationToken.None, 667CancellationToken = CancellationToken.None, 717CancellationToken = CancellationToken.None,
Aspire.Hosting.Foundry.Tests (1)
PromptAgentTests.cs (1)
191CancellationToken = cts.Token,
Aspire.Hosting.Maui.Tests (1)
MauiBuildQueueTests.cs (1)
1177CancellationToken = CancellationToken.None,
Aspire.Hosting.MongoDB.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = cancellation.Token,
Aspire.Hosting.MySql.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = cancellation.Token,
Aspire.Hosting.PostgreSQL.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = cancellation.Token,
Aspire.Hosting.Redis.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = cancellation.Token,
Aspire.Hosting.SqlServer.Tests (2)
tests\Shared\ContainerReplCommandTestBase.cs (2)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = 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)
88CancellationToken = TestContext.Current.CancellationToken, 111CancellationToken = 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); 454return 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)
3684var processResult = await pendingProcessResult.WaitAsync(context.CancellationToken).ConfigureAwait(false); 3687catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested) 3861CancellationToken = context.CancellationToken, 4123CancellationToken = context.CancellationToken, 4133response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false); 4141CancellationToken = context.CancellationToken, 4149return await GetDefaultHttpCommandResultAsync(response, commandOptions, context.CancellationToken).ConfigureAwait(false); 4151catch (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)
405.GetValueAsync(context.CancellationToken) 420.GetValueAsync(context.CancellationToken) 444context.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)
883context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore (10)
EFResourceBuilderExtensions.cs (10)
512.BuildAsync(executionContext, context.Logger, context.CancellationToken).ConfigureAwait(false); 541context.CancellationToken).ConfigureAwait(false); 586process.StandardOutput, resourceLogger, isErrorOutput: false, captureBuilder: null, context.CancellationToken); 588process.StandardError, resourceLogger, isErrorOutput: true, captureBuilder: stderrBuilder, context.CancellationToken); 591await process.WaitForExitAsync(context.CancellationToken).ConfigureAwait(false); 931await resourceNotificationService.WaitForDependenciesAsync(migrationResource, context.CancellationToken).ConfigureAwait(false); 941context.CancellationToken, 1018cancellationToken: context.CancellationToken).ConfigureAwait(false); 1060cancellationToken: context.CancellationToken).ConfigureAwait(false); 1099cancellationToken: context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore.Tests (1)
TestServices\TestEfTool.cs (1)
34context.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)
829await stopCompletion.Task.WaitAsync(context.CancellationToken); 868await Task.Delay(Timeout.InfiniteTimeSpan, context.CancellationToken); 1006await 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)
1941await Task.Delay(Timeout.Infinite, e.CancellationToken); 1989await Task.Delay(Timeout.Infinite, e.CancellationToken); 1991catch (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)
1188await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StopCommand, c.CancellationToken); 1197await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StartCommand, c.CancellationToken);
InteractionCommands.cs (27)
21var resultTask1 = interactionService.PromptConfirmationAsync("Command confirmation", "Are you sure?", cancellationToken: commandContext.CancellationToken); 22var resultTask2 = interactionService.PromptMessageBoxAsync("Command confirmation", "Are you really sure?", new MessageBoxInteractionOptions { Intent = MessageIntent.Warning, ShowSecondaryButton = true }, cancellationToken: commandContext.CancellationToken); 141cancellationToken: commandContext.CancellationToken); 191cancellationToken: commandContext.CancellationToken); 277cancellationToken: commandContext.CancellationToken); 371cancellationToken: commandContext.CancellationToken); 497cancellationToken: commandContext.CancellationToken); 597cancellationToken: commandContext.CancellationToken); 630cancellationToken: commandContext.CancellationToken); 638cancellationToken: commandContext.CancellationToken); 646cancellationToken: commandContext.CancellationToken); 656cancellationToken: commandContext.CancellationToken); 679cancellationToken: commandContext.CancellationToken); 870commandContext.CancellationToken); 907commandContext.CancellationToken); 934cancellationToken: commandContext.CancellationToken); 952using var cts = CancellationTokenSource.CreateLinkedTokenSource(commandContext.CancellationToken); 960await Task.Delay(10000, commandContext.CancellationToken); 986commandContext.CancellationToken); 1009cancellationToken: commandContext.CancellationToken); 1034commandContext.CancellationToken); 1054commandContext.CancellationToken); 1072await Task.Delay(10000, commandContext.CancellationToken); 1101cancellationToken: commandContext.CancellationToken); 1116var content = await file.ReadAllBytesAsync(commandContext.CancellationToken); 1148cancellationToken: commandContext.CancellationToken); 1168var 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);