CancellationToken

83 writes to CancellationToken

Aspire.Hosting (2)

ApplicationModel\ResourceCommandService.cs (2)

370CancellationToken = cancellationToken, 444CancellationToken = linkedCts.Token,

Aspire.Hosting.Azure.Tests (61)

AzureEnvironmentResourceExtensionsTests.cs (61)

360CancellationToken = CancellationToken.None, 414CancellationToken = CancellationToken.None, 752CancellationToken = CancellationToken.None, 833CancellationToken = CancellationToken.None, 917CancellationToken = CancellationToken.None, 1186CancellationToken = CancellationToken.None, 1250CancellationToken = CancellationToken.None, 1311CancellationToken = CancellationToken.None, 1372CancellationToken = CancellationToken.None, 1507CancellationToken = CancellationToken.None, 1565CancellationToken = CancellationToken.None, 1616CancellationToken = CancellationToken.None, 1628CancellationToken = CancellationToken.None, 1712CancellationToken = CancellationToken.None, 1796CancellationToken = CancellationToken.None, 1890CancellationToken = CancellationToken.None, 1961CancellationToken = CancellationToken.None, 2039CancellationToken = CancellationToken.None, 2053CancellationToken = CancellationToken.None, 2118CancellationToken = CancellationToken.None, 2182CancellationToken = CancellationToken.None, 2236CancellationToken = CancellationToken.None, 2296CancellationToken = CancellationToken.None, 2373CancellationToken = CancellationToken.None, 2387CancellationToken = CancellationToken.None, 2450CancellationToken = CancellationToken.None, 2467CancellationToken = CancellationToken.None, 2548CancellationToken = CancellationToken.None, 2594CancellationToken = CancellationToken.None, 2647CancellationToken = CancellationToken.None, 2661CancellationToken = CancellationToken.None, 2714CancellationToken = CancellationToken.None, 2787CancellationToken = CancellationToken.None, 2840CancellationToken = CancellationToken.None, 2900CancellationToken = CancellationToken.None, 2961CancellationToken = CancellationToken.None, 3031CancellationToken = CancellationToken.None, 3092CancellationToken = CancellationToken.None, 3161CancellationToken = CancellationToken.None, 3218CancellationToken = CancellationToken.None, 3281CancellationToken = CancellationToken.None, 3352CancellationToken = CancellationToken.None, 3407CancellationToken = CancellationToken.None, 3447CancellationToken = CancellationToken.None, 3521CancellationToken = CancellationToken.None, 3569CancellationToken = CancellationToken.None, 3625CancellationToken = CancellationToken.None, 3772CancellationToken = CancellationToken.None, 3851CancellationToken = CancellationToken.None, 3923CancellationToken = CancellationToken.None, 4003CancellationToken = CancellationToken.None, 4077CancellationToken = CancellationToken.None, 4129CancellationToken = CancellationToken.None, 4175CancellationToken = CancellationToken.None, 4221CancellationToken = CancellationToken.None, 4289CancellationToken = cts.Token, 4528CancellationToken = CancellationToken.None, 4580CancellationToken = CancellationToken.None, 4627CancellationToken = CancellationToken.None, 4675CancellationToken = CancellationToken.None, 4813CancellationToken = CancellationToken.None,

Aspire.Hosting.Blazor.Tests (2)

BlazorHostedExtensionsTests.cs (1)

272CancellationToken = CancellationToken.None,

WithBlazorAppTests.cs (1)

324CancellationToken = CancellationToken.None,

Aspire.Hosting.DevTunnels.Tests (3)

DevTunnelResourceBuilderExtensionsTests.cs (3)

569CancellationToken = CancellationToken.None, 621CancellationToken = CancellationToken.None, 669CancellationToken = CancellationToken.None,

Aspire.Hosting.Foundry.Tests (1)

PromptAgentTests.cs (1)

103CancellationToken = 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.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,

140 references to CancellationToken

Aspire.Hosting (22)

ApplicationModel\CommandOptions.cs (1)

137/// <see cref="ExecuteCommandContext.CancellationToken"/>.

ApplicationModel\CommandsConfigurationExtensions.cs (11)

32await orchestrator.StartResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 65await orchestrator.StopResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 104await orchestrator.StopResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 105await orchestrator.StartResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 227await Task.WhenAll(replicasToStop.Select(name => orchestrator.StopResourceAsync(name, context.CancellationToken))).ConfigureAwait(false); 239using var logCts = CancellationTokenSource.CreateLinkedTokenSource(context.CancellationToken); 259await orchestrator.StartResourceAsync(rebuilderInstanceName, context.CancellationToken).ConfigureAwait(false); 263using var buildTimeoutCts = CancellationTokenSource.CreateLinkedTokenSource(context.CancellationToken); 278catch (OperationCanceledException) when (!context.CancellationToken.IsCancellationRequested) 321await orchestrator.StartResourceAsync(name, context.CancellationToken).ConfigureAwait(false); 356catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested)

Orchestrator\ParameterProcessor.cs (2)

267executeCommand: context => SetParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken), 303executeCommand: context => DeleteParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken),

ResourceBuilderExtensions.cs (8)

3414var processResult = await pendingProcessResult.WaitAsync(context.CancellationToken).ConfigureAwait(false); 3417catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested) 3591CancellationToken = context.CancellationToken, 3853CancellationToken = context.CancellationToken, 3863response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false); 3871CancellationToken = context.CancellationToken, 3879return await GetDefaultHttpCommandResultAsync(response, commandOptions, context.CancellationToken).ConfigureAwait(false); 3881catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested)

Aspire.Hosting.Azure (19)

AzureProvisioningController.cs (19)

738() => RunOperationAsync<bool>(model, new ResetStateIntent(ReprovisionAfterReset: true), context.CancellationToken), 740() => CreateEnvironmentCommandResultDataAsync(ResetProvisioningStateCommandName, model, context.CancellationToken), 751() => ChangeAzureContextCommandAsync(model, context.Arguments, context.CancellationToken), 753() => CreateEnvironmentCommandResultDataAsync(ChangeAzureContextCommandName, model, context.CancellationToken), 764() => ReprovisionAllAsync(model, context.CancellationToken), 766() => CreateEnvironmentCommandResultDataAsync(ReprovisionAllCommandName, model, context.CancellationToken), 777() => DeleteAzureResourcesAsync(model, context.CancellationToken), 779() => CreateEnvironmentCommandResultDataAsync(DeleteAzureResourcesCommandName, model, context.CancellationToken)); 790() => ChangeResourceLocationCommandAsync(model, resourceName, context.Arguments, context.CancellationToken), 792() => CreateResourceCommandResultDataAsync(ChangeResourceLocationCommandName, model, resourceName, context.CancellationToken), 806() => CreateAzureResourceInfoCommandResultDataAsync(model, resourceName, context.CancellationToken)); 817() => CancelResourceAsync(model, resourceName, context.CancellationToken), 819() => CreateResourceCommandResultDataAsync(CancelCommandName, model, resourceName, context.CancellationToken)); 830() => RunOperationAsync<DeleteAzureResourceResult>(model, new DeleteAzureResourceIntent(resourceName), context.CancellationToken), 832result => CreateDeleteAzureResourceCommandResultDataAsync(model, resourceName, result, context.CancellationToken)); 843() => ForgetResourceStateAsync(model, resourceName, context.CancellationToken), 845() => CreateResourceCommandResultDataAsync(ForgetStateCommandName, model, resourceName, context.CancellationToken)); 856() => ReprovisionResourceAsync(model, resourceName, context.CancellationToken), 858() => 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)

863context.CancellationToken).ConfigureAwait(false);

Aspire.Hosting.EntityFrameworkCore (10)

EFResourceBuilderExtensions.cs (10)

520.BuildAsync(executionContext, context.Logger, context.CancellationToken).ConfigureAwait(false); 549context.CancellationToken).ConfigureAwait(false); 594process.StandardOutput, resourceLogger, isErrorOutput: false, captureBuilder: null, context.CancellationToken); 596process.StandardError, resourceLogger, isErrorOutput: true, captureBuilder: stderrBuilder, context.CancellationToken); 599await process.WaitForExitAsync(context.CancellationToken).ConfigureAwait(false); 939await resourceNotificationService.WaitForDependenciesAsync(migrationResource, context.CancellationToken).ConfigureAwait(false); 949context.CancellationToken, 1026cancellationToken: context.CancellationToken).ConfigureAwait(false); 1068cancellationToken: context.CancellationToken).ConfigureAwait(false); 1107cancellationToken: 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)

1842await Task.Delay(Timeout.Infinite, e.CancellationToken); 1890await Task.Delay(Timeout.Infinite, e.CancellationToken); 1892catch (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)

1110await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StopCommand, c.CancellationToken); 1119await 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);