Register

104 references to Register

aspire (4)

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

741using var cancellationRegistration = cancellationToken.Register(() => tcs.TrySetCanceled());

Commands\BaseCommand.cs (1)

147using var stoppingMessageRegistration = cancellationToken.Register(() =>

Projects\ProcessGuestLauncher.cs (1)

159using var _ = cancellationToken.Register(() =>

Telemetry\InternalMicrosoftDetector.cs (1)

294using var stageTimeoutRegistration = stageTimeout.Token.Register(

Aspire.Cli.Tests (8)

Backchannel\ResourceSnapshotWatcherTests.cs (2)

32using var registration = cancellationToken.Register(() => getCancellationRequested.TrySetResult()); 671using var registration = cancellationToken.Register(

Commands\DescribeCommandTests.cs (1)

1064using var registration = cancellationToken.Register(() => waitForCancellation.TrySetResult());

Commands\LogsCommandTests.cs (2)

1643await using (cancellationToken.Register(() => tcs.TrySetResult())) 1702using var registration = cancellationToken.Register(() => waitForCancellation.TrySetResult());

Processes\LauncherLivenessMonitorTests.cs (1)

36await using var registration = runCts.Token.Register(() => cancelTcs.TrySetResult());

Telemetry\InternalMicrosoftDetectorTests.cs (1)

261using var registration = cancellationToken.Register(stageCancelled.SetResult);

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Dashboard (2)

DashboardWebApplication.cs (1)

412_app.Lifetime.ApplicationStarted.Register(() =>

Model\TraceLinkHelpers.cs (1)

49using var registration = cancellationToken.Register(cts.Cancel);

Aspire.Dashboard.Components.Tests (2)

Dialogs\FilterDialogTests.cs (1)

403cancellationToken.Register(() => readCancelled.TrySetResult());

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Dashboard.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting (2)

ApplicationModel\ResourceLoggerService.cs (1)

462using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete());

Lifecycle\TerminalHostOrphanCleanupService.cs (1)

32applicationLifetime.ApplicationStopped.Register(DeleteRegisteredReplicaFiles);

Aspire.Hosting.Azure.Kusto.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Blazor.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Browsers.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Containers.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.DevTunnels (1)

DevTunnelCli.cs (1)

264using var ctr = cancellationToken.Register(() =>

Aspire.Hosting.DevTunnels.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Dotnet.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.DotnetTool.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Foundry.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.GitHub.Models.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.JavaScript.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Kafka.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Maui.Tests (2)

MauiBuildQueueTests.cs (2)

43using var _ = cts.Token.Register(() => throw new InvalidOperationException("callback failure")); 1255using var reg = cancellationToken.Register(() => tcs.TrySetCanceled(cancellationToken));

Aspire.Hosting.MySql.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.OpenAI.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.PostgreSQL.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.RabbitMQ.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.RemoteHost (1)

JsonRpcServer.cs (1)

240using var registration = cancellationToken.Register(() =>

Aspire.Hosting.Testing.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Tests (2)

Health\ResourceHealthCheckServiceTests.cs (1)

176monitor1.CancellationToken.Register(monitorStoppedTcs.SetResult);

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Hosting.Valkey.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.Managed.Tests (2)

ParentProcessWatchdogTests.cs (2)

45using var registration = operationCts.Token.Register(static () => throw new InvalidOperationException("simulated cancellation callback failure")); 64using var registration = operationCts.Token.Register(() =>

Aspire.Playground.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

Aspire.TerminalHost.Tests (1)

tests\Shared\AsyncTestHelpers.cs (1)

245token.Register(() => tcs.SetCanceled(token));

dotnet-aot (1)

parent\dotnet\Commands\Test\MTP\TestApplication.cs (1)

680_pipeCancellationTokenSource.Token.Register(

dotnet-format (1)

Utilities\ProcessRunner.cs (1)

123_ = cancellationToken.Register(() =>

dotnet-svcutil-lib (2)

Shared\Utilities\AsyncHelper.cs (2)

24using (cancellationToken.Register(() => taskCompletionSrc.SetCanceled())) 48using (cancellationToken.Register(() => taskCompletionSrc.SetCanceled()))

GetDocument.Insider (1)

Commands\GetDocumentCommandWorker.cs (1)

139using (var registration = applicationLifetime.ApplicationStarted.Register(() => waitForStartTcs.TrySetResult(null)))

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSRuntime.cs (1)

197cancellationTokenSource.Token.Register(() =>

Microsoft.AspNetCore.Components.Testing (1)

Infrastructure\ReadinessNotificationService.cs (1)

30_lifetime.ApplicationStarted.Register(() =>

Microsoft.AspNetCore.Components.WebAssembly (1)

Hosting\WebAssemblyHost.cs (1)

165using (cancellationToken.Register(() => tcs.TrySetResult()))

Microsoft.AspNetCore.Components.WebAssembly.Server (1)

DebugProxyLauncher.cs (1)

87ctr = cts.Token.Register(() =>

Microsoft.AspNetCore.Hosting.WindowsServices (1)

WebHostService.cs (1)

53.Register(() =>

Microsoft.AspNetCore.Http.Connections (2)

Internal\HttpConnectionManager.cs (2)

39appLifetime.ApplicationStarted.Register(Start); 40appLifetime.ApplicationStopping.Register(CloseConnections);

Microsoft.AspNetCore.Server.IntegrationTesting (1)

src\aspnetcore\src\Shared\Process\ProcessEx.cs (1)

63_processTimeoutCts.Token.Register(() =>

Microsoft.AspNetCore.Server.Kestrel.Core (1)

Internal\Infrastructure\TransportConnectionManager.cs (1)

102token.Register(tcs.SetResult);

Microsoft.AspNetCore.SpaProxy (1)

SpaProxyLaunchManager.cs (1)

30appLifetime.ApplicationStopping.Register(() => Dispose(true));

Microsoft.AspNetCore.SpaServices.Extensions (1)

Npm\NodeScriptRunner.cs (1)

64applicationStoppingToken.Register(((IDisposable)this).Dispose);

Microsoft.AspNetCore.TestHost (2)

HttpContextBuilder.cs (1)

86var registration = cancellationToken.Register(ClientInitiatedAbort);

ResponseBodyReaderStream.cs (1)

86using var registration = cancellationToken.Register(Cancel);

Microsoft.Build (1)

BackEnd\TaskExecutionHost\TaskExecutionHost.cs (1)

298_cancellationTokenRegistration = cancellationToken.Register(Cancel);

Microsoft.CodeAnalysis (1)

DiagnosticAnalyzer\AnalyzerDriver.cs (1)

681_lazyQueueRegistration = cancellationToken.Register(() =>

Microsoft.CodeAnalysis.Analyzers (1)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.CodeStyle (1)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.ResxSourceGenerator (1)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

Microsoft.Diagnostics.NETCore.Client (5)

DiagnosticsIpc\IpcSocket.cs (2)

29using (token.Register(() => Close(0))) 69using (token.Register(() => Close(0)))

DiagnosticsServerRouter\DiagnosticsServerRouterFactory.cs (1)

516using (token.Register(() => clientSocket.Close(0)))

HandleableCollection.cs (2)

144using CancellationTokenRegistration _ = cancellation.Token.Register( 177using CancellationTokenRegistration _ = token.Register(() => completionSource.TrySetCanceled(token));

Microsoft.DotNet.HotReload.Watch (6)

Build\ProjectBuildManager.cs (1)

50using var _ = buildCancellationTokenSource.Token.Register(manager.CancelAllSubmissions);

FileWatcher\FileWatcher.cs (1)

183cancellationToken.Register(() => fileChangedSource.TrySetResult(null));

HotReload\HotReloadDotNetWatcher.cs (1)

206mainRunningProject.Process.ExitedCancellationToken.Register(iterationCancellationSource.Cancel);

src\sdk\src\Dotnet.Watch\AspireService\AspireServerService.cs (1)

294using var shutdownRegistration = _shutdownCancellationSource.Token.Register(() => socketTcs.TrySetResult());

src\sdk\src\Dotnet.Watch\AspireService\Helpers\WebSocketConnection.cs (1)

49var cancelTokenRegistration = HttpRequestAborted.Register(() => callback(this));

src\sdk\src\Dotnet.Watch\HotReloadClient\Web\AbstractBrowserRefreshServer.cs (1)

184cancellationToken.Register(() => _browserConnected.TrySetCanceled());

Microsoft.Extensions.Caching.Hybrid.Tests (4)

StampedeTests.cs (4)

101using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 137using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 190using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 271using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount));

Microsoft.Extensions.Diagnostics.Testing (1)

Metrics\MetricCollector.cs (1)

229_ = cancellationToken.Register(() =>

Microsoft.Extensions.Hosting.WindowsServices (4)

WindowsServiceLifetime.cs (4)

77cancellationToken.Register(() => _delayStart.TrySetCanceled()); 78ApplicationLifetime.ApplicationStarted.Register(() => 86ApplicationLifetime.ApplicationStopping.Register(() => 90ApplicationLifetime.ApplicationStopped.Register(_delayStop.Set);

Microsoft.JSInterop (1)

JSRuntime.cs (1)

146_cancellationRegistrations[taskId] = cancellationToken.Register(() =>

Microsoft.Maui.Controls (3)

LockingSemaphore.cs (1)

47 token.Register(() => waiter.TrySetCanceled());

StreamImageSource.cs (1)

39 userToken.Register(CancellationTokenSource.Cancel);

UriImageSource.cs (1)

60 userToken.Register(CancellationTokenSource.Cancel);

Microsoft.TestPlatform.CrossPlatEngine (1)

AttachmentsProcessing\TestRunAttachmentsProcessingManager.cs (1)

68using (cancellationToken.Register(() => cancelAttachmentProcessingCompletionSource.TrySetCanceled()))

Microsoft.TestPlatform.VsTestConsole.TranslationLayer (1)

VsTestConsoleRequestSender.cs (1)

939using (cancellationToken.Register(() =>

NuGet.Credentials (1)

PluginCredentialProvider.cs (1)

289using (cancellationToken.Register(() => Kill(process)))

NuGet.Protocol (3)

Plugins\OutboundRequestContext`1.cs (1)

124_cancellationTokenSource.Token.Register(TryCancel);

Plugins\RequestHandlers\SymmetricHandshake.cs (1)

78_timeoutCancellationTokenSource.Token.Register(() =>

Utility\TimeoutUtility.cs (1)

37using (token.Register(() => taskTcs.Cancel()))

Roslyn.Diagnostics.Analyzers (1)

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

Stress.ApiService (3)

Program.cs (3)

38app.Lifetime.ApplicationStarted.Register(ConsoleStresser.Stress); 40app.Lifetime.ApplicationStarted.Register(() => 285cancellationToken.Register(() =>