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