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