Register

207 references to Register

aspire (1)

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

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

Aspire.Dashboard (4)

DashboardWebApplication.cs (1)

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

Model\Assistant\AIHelpers.cs (1)

311messageCts.Token.Register(responseCts.Cancel);

Model\DashboardCommandExecutor.cs (1)

132closeToastCts.Token.Register(() =>

Model\TraceLinkHelpers.cs (1)

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

Aspire.Hosting (1)

ApplicationModel\ResourceLoggerService.cs (1)

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

Aspire.Hosting.DevTunnels (1)

DevTunnelCli.cs (1)

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

Aspire.Hosting.Tests (1)

Health\ResourceHealthCheckServiceTests.cs (1)

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

aspire-server (1)

JsonRpcServer.cs (1)

219using var registration = 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)

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

HelixTestRunner (1)

ProcessUtil.cs (1)

173await using var _ = cancellationToken.Register(() => canceledTcs.TrySetResult(null));

HttpStress (1)

Program.cs (1)

674using (_cancellationToken.Register(() => tcs.SetResult()))

IIS.Tests (4)

ClientDisconnectTests.cs (2)

32ctx.RequestAborted.Register(() => requestAborted.SetResult(true)); 328ctx.RequestAborted.Register(() => requestAborted.SetResult(true));

ResponseAbortTests.cs (1)

152var originalRegistration = token.Register(() => { });

Utilities\TestServer.cs (1)

184lifetime.ApplicationStopping.Register(() => doneEvent.Set());

InMemory.FunctionalTests (19)

Http2\Http2ConnectionTests.cs (4)

3223context.RequestAborted.Register(() => 3343context.RequestAborted.Register(() => 4249context.RequestAborted.Register(() => 4353context.RequestAborted.Register(() =>

Http2\Http2StreamTests.cs (4)

3181context.RequestAborted.Register(() => 3214context.RequestAborted.Register(() => 3336context.RequestAborted.Register(() => 3376context.RequestAborted.Register(() =>

Http2\Http2TestBase.cs (3)

272context.RequestAborted.Register(() => 295context.RequestAborted.Register(() => 315context.RequestAborted.Register(() =>

Http3\Http3ConnectionTests.cs (1)

327lifetime.ConnectionClosedRequested.Register(() => completionSource.TrySetResult());

Http3\Http3StreamTests.cs (1)

3288Http3Api.MultiplexedConnectionContext.ConnectionClosed.Register(() => tcs.TrySetResult());

KeepAliveTimeoutTests.cs (1)

313token.Register(() => tcs.SetResult());

KestrelMetricsTests.cs (4)

237notificationFeature.ConnectionClosedRequested.Register(() => 293connection.TransportConnection.ConnectionClosed.Register(() => 585notificationFeature.ConnectionClosedRequested.Register(() => 632connection.TransportConnection.ConnectionClosed.Register(() => tcs.TrySetResult());

ResponseTests.cs (1)

1220httpContext.RequestAborted.Register(() =>

Interop.FunctionalTests (14)

Http3\Http3RequestTests.cs (11)

HttpClientHttp2InteropTests.cs (3)

914context.RequestAborted.Register(() => serverResult.SetResult()); 955context.RequestAborted.Register(() => serverResult.SetResult()); 995context.RequestAborted.Register(() => serverResult.SetResult());

InteropTests (1)

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

63_processTimeoutCts.Token.Register(() =>

InteropWebsite (1)

Startup.cs (1)

38applicationLifetime.ApplicationStarted.Register(() =>

Metrics (1)

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

334using var _ = cancellationToken.Register(

Metrics.Legacy (1)

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

334using var _ = cancellationToken.Register(

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSRuntime.cs (1)

191cancellationTokenSource.Token.Register(() =>

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

Circuits\RevalidatingServerAuthenticationStateProviderTest.cs (1)

163firstRevalidationCall.CancellationToken.Register(() => validationTcs.TrySetCanceled(firstRevalidationCall.CancellationToken));

Microsoft.AspNetCore.Components.Tests (1)

Routing\RouterTest.cs (1)

138args.CancellationToken.Register(() => cancelled = args.Path);

Microsoft.AspNetCore.Components.Web.Tests (1)

Media\ImageTest.cs (1)

198cancellationToken.Register(() => tcs.TrySetException(new OperationCanceledException(cancellationToken)));

Microsoft.AspNetCore.Components.WebAssembly (1)

Hosting\WebAssemblyHost.cs (1)

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

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

DebugProxyLauncher.cs (1)

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

Microsoft.AspNetCore.Hosting.FunctionalTests (1)

WebHostBuilderTests.cs (1)

51deploymentResult.HostShutdownToken.Register(tcs.SetResult);

Microsoft.AspNetCore.Hosting.Tests (5)

HostingApplicationDiagnosticsTests.cs (1)

41timeoutTokenSource.Token.Register(() => Logger.LogError("Timeout while waiting for counter value."));

Internal\HostingEventSourceTests.cs (1)

200timeoutTokenSource.Token.Register(() => Logger.LogError("Timeout while waiting for counter value."));

WebHostTests.cs (3)

325lifetime.ApplicationStarted.Register(() => 330lifetime.ApplicationStopping.Register(() => 341lifetime.ApplicationStopped.Register(() =>

Microsoft.AspNetCore.Hosting.TestSites (3)

StartupShutdown.cs (3)

16lifetime.ApplicationStarted.Register(() => 20lifetime.ApplicationStopping.Register(() => 26lifetime.ApplicationStopped.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.Http.Connections.Tests (4)

HttpConnectionDispatcherTests.cs (4)

2941connection.ConnectionClosed.Register(() => tcs.SetResult()); 2945lifetimeFeature.RequestAborted.Register(() => tcs.SetResult()); 3150connection.ConnectionClosedRequested.Register(() => tcs.SetResult()); 4026connection.ConnectionClosed.Register(() =>

Microsoft.AspNetCore.Http.Results.Tests (1)

ServerSentEventsResultTests.cs (1)

254cancellationToken.Register(cancellationObserved.SetResult);

Microsoft.AspNetCore.Mvc.FunctionalTests (1)

TestingInfrastructureInheritanceTests.cs (1)

76lifetimeService.ApplicationStopped.Register(() => { callbackCalled = true; });

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (18)

Listener\ResponseBodyTests.cs (8)

Listener\ServerTests.cs (3)

42ct.Register(() => canceled.SetResult()); 73ct.Register(() => canceled.SetResult()); 96ct.Register(() => canceled.SetResult());

RequestTests.cs (1)

513ct.Register(() => result.SetResult());

ResponseSendFileTests.cs (4)

487httpContext.RequestAborted.Register(() => cancellationReceived.SetResult()); 540httpContext.RequestAborted.Register(() => cancellationReceived.SetResult()); 587httpContext.RequestAborted.Register(() => cancellationReceived.SetResult()); 639httpContext.RequestAborted.Register(() => cancellationReceived.SetResult());

ServerTests.cs (2)

287ct.Register(() => canceled.SetResult()); 320ct.Register(() => canceled.SetResult());

Microsoft.AspNetCore.Server.IISIntegration.Tests (4)

IISMiddlewareTests.cs (4)

117appLifetime.ApplicationStopping.Register(() => applicationStoppingFired.SetResult()); 176appLifetime.ApplicationStopping.Register(() => applicationStoppingFired.SetResult()); 221appLifetime.ApplicationStopping.Register(() => applicationStoppingFired.SetResult()); 266appLifetime.ApplicationStopping.Register(() => applicationStoppingFired.SetResult());

Microsoft.AspNetCore.Server.IntegrationTesting (1)

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.Server.Kestrel.Core.Tests (3)

Http1\Http1ConnectionTests.cs (2)

788var originalRegistration = originalToken.Register(() => { }); 802var originalRegistration = originalToken.Register(() => { });

HttpConnectionTests.cs (1)

37http1Connection.RequestAborted.Register(() =>

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (5)

QuicConnectionContextTests.cs (3)

131serverConnection.ConnectionClosed.Register(() => connectionClosedTcs.SetResult()); 171serverStream.ConnectionClosed.Register(() => closedTcs.SetResult()); 214serverStream.ConnectionClosed.Register(() => closedTcs.SetResult());

QuicStreamContextTests.cs (2)

271serverStream.ConnectionClosed.Register(() => closedTcs.SetResult()); 349serverStream.ConnectionClosed.Register(() => closedTcs.SetResult());

Microsoft.AspNetCore.SignalR.Client.Tests (10)

HttpConnectionTests.ConnectionLifecycle.cs (1)

296cancellationToken.Register(() =>

HttpConnectionTests.Negotiate.cs (3)

283token.Register(() => tcs.TrySetResult(ResponseUtils.CreateResponse(HttpStatusCode.NoContent))); 387token.Register(() => tcs.TrySetResult(ResponseUtils.CreateResponse(HttpStatusCode.NoContent))); 452token.Register(() => tcs.TrySetResult(ResponseUtils.CreateResponse(HttpStatusCode.NoContent)));

HttpConnectionTests.Transport.cs (1)

584cancellationToken.Register(() => _tcs.TrySetResult());

LongPollingTransportTests.cs (2)

481cancellationToken.Register(() => tcs.TrySetCanceled(cancellationToken)); 549cancellationToken.Register(() => pollTcs.TrySetCanceled(cancellationToken));

ServerSentEventsTransportTests.cs (2)

191using (ct.Register(() => readTcs.TrySetCanceled())) 244using (ct.Register(() => readTcs.TrySetCanceled()))

TestHttpMessageHandler.cs (1)

115using (cts.Token.Register(() => tcs.TrySetResult()))

Microsoft.AspNetCore.SignalR.Tests (2)

HubConnectionHandlerTestUtils\Hubs.cs (2)

1242Context.ConnectionAborted.Register(() => 1271Context.ConnectionAborted.Register(() =>

Microsoft.AspNetCore.SignalR.Tests.Utils (1)

src\Shared\SignalR\InProcessTestServer.cs (1)

132_lifetime.ApplicationStopped.Register(() =>

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.AspNetCore.TestHost.Tests (3)

HttpContextBuilderTests.cs (1)

467context.RequestAborted.Register(() => requestAborted.SetResult());

RequestLifetimeTests.cs (1)

21httpContext.RequestAborted.Register(() => requestAborted.SetResult());

ResponseResetTests.cs (1)

72httpContext.RequestAborted.Register(() => requestAborted.SetResult());

Microsoft.AspNetCore.WebSockets.ConformanceTests (2)

Autobahn\Executable.cs (1)

49using (cancellationToken.Register(() => Cancel(process, tcs)))

AutobahnTests.cs (1)

55using (cts.Token.Register(() => logger.LogError("Test run is taking longer than maximum duration of {timeoutMinutes:0.00} minutes. Aborting...", TestTimeout.TotalMinutes)))

Microsoft.AspNetCore.WebSockets.Tests (1)

BufferStream.cs (1)

173var registration = cancellationToken.Register(Abort);

Microsoft.CodeAnalysis (1)

DiagnosticAnalyzer\AnalyzerDriver.cs (1)

681_lazyQueueRegistration = cancellationToken.Register(() =>

Microsoft.CodeAnalysis.Analyzers (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.BannedApiAnalyzers (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.CodeStyle (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.EditorFeatures (1)

GoOrFind\AbstractGoOrFindNavigationService.cs (1)

239presenterCancellationToken.Register(() => cancellationTokenSource.Cancel());

Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (1)

Threading\TaskJoinExtensions.cs (1)

49using (var registration = cancellationToken.Register(() => frame.Continue = false))

Microsoft.CodeAnalysis.InteractiveHost (1)

Interactive\Core\InteractiveHost.LazyRemoteService.cs (1)

89cancellationToken.Register(() =>

Microsoft.CodeAnalysis.LanguageServer (4)

FileBasedPrograms\VirtualProjectXmlProvider.cs (1)

35cancellationToken.Register(() =>

LanguageServer\Handler\Restore\RestoreHandler.cs (1)

106cancellationToken.Register(() =>

Testing\TestDiscoverer.cs (1)

61cancellationToken.Register(() => vsTestConsoleWrapper.CancelDiscovery());

Testing\TestRunner.cs (1)

47cancellationToken.Register(() => vsTestConsoleWrapper.CancelTestRun());

Microsoft.CodeAnalysis.LanguageServer.Protocol (2)

Handler\WorkDoneProgress\WorkDoneProgressManager.cs (1)

113serverCancellationToken.Register(() =>

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\QueueItem.cs (1)

57cancellationToken.Register(() => _completionSource.TrySetCanceled(cancellationToken));

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.PublicApiAnalyzers (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.ResxSourceGenerator (1)

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

334using var _ = cancellationToken.Register(

Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)

Build\ProjectBuildManager.cs (1)

395registration = cancellationToken.Register(() =>

Microsoft.CodeAnalysis.Workspaces.UnitTests (1)

UtilityTest\CancellationSeriesTests.cs (1)

124token1.Register(() => throw exception);

Microsoft.CommonLanguageServerProtocol.Framework.Package (1)

QueueItem.cs (1)

57cancellationToken.Register(() => _completionSource.TrySetCanceled(cancellationToken));

Microsoft.Extensions.ApiDescription.Client.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

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)); 268using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount));

Microsoft.Extensions.Diagnostics.HealthChecks.Tests (1)

DefaultHealthCheckServiceTest.cs (1)

578token.Register(() => throw new OperationCanceledException(token));

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.Extensions.Http.Polly.Tests (1)

PolicyHttpMessageHandlerTest.cs (1)

397token.Register(() => throw new OperationCanceledException(token));

Microsoft.Extensions.Validation.GeneratorTests (1)

ValidationsGeneratorTestBase.cs (1)

202using var registration = applicationLifetime.ApplicationStarted.Register(() => waitForStartTcs.TrySetResult(0));

Microsoft.JSInterop (1)

JSRuntime.cs (1)

135_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.ML.AutoML (5)

API\BinaryClassificationExperiment.cs (1)

452using (var ctRegistration = ct.Register(() =>

API\MulticlassClassificationExperiment.cs (1)

430using (var ctRegistration = ct.Register(() =>

API\RegressionExperiment.cs (1)

384using (var ctRegistration = ct.Register(() =>

AutoMLExperiment\IStopTrainingManager.cs (1)

34ct.Register(() =>

AutoMLExperiment\Runner\SweepablePipelineRunner.cs (1)

98using (var ctRegistration = ct.Register(() =>

Microsoft.VisualStudio.LanguageServices.CSharp (1)

SemanticSearch\SemanticSearchToolWindowImpl.cs (1)

419presenterCancellationToken.Register(() => cancellationSource?.Cancel());

Microsoft.VisualStudio.LanguageServices.LiveShare (1)

Client\RemoteLanguageServiceWorkspaceHost.cs (1)

91using var token = cancellationToken.Register(() =>

Roslyn.Diagnostics.Analyzers (1)

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

334using var _ = cancellationToken.Register(

Roslyn.Test.Performance.Utilities (1)

TestUtilities.cs (1)

140cancellationToken.Register(() => process.Kill());

RunTests (1)

ProcessRunner.cs (1)

140var registration = cancellationToken.Register(() =>

SignalRSamples (1)

ObservableExtensions.cs (1)

32var abortRegistration = connectionAborted.Register(() => channel.Writer.TryComplete());

Sockets.FunctionalTests (15)

src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (6)

666token.Register(() => requestAborted.Release(2)); 703context.RequestAborted.Register(() => 805connectionLifetimeFeature.ConnectionClosed.Register(() => connectionClosedTcs.SetResult()); 837connectionLifetimeFeature.ConnectionClosed.Register(() => connectionClosedTcs.SetResult()); 873connectionLifetimeFeature.ConnectionClosed.Register(() => connectionClosedTcs.SetResult()); 925lifetime.RequestAborted.Register(() => registrationTcs.TrySetResult(requestId));

src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (9)

Stress.ApiService (3)

Program.cs (3)

37app.Lifetime.ApplicationStarted.Register(ConsoleStresser.Stress); 39app.Lifetime.ApplicationStarted.Register(() => 241cancellationToken.Register(() =>

Templates.Blazor.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

Templates.Blazor.WebAssembly.Auth.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

Templates.Blazor.WebAssembly.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

Templates.Mvc.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

Templates.Tests (1)

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

63_processTimeoutCts.Token.Register(() =>

Text.Analyzers (1)

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

334using var _ = cancellationToken.Register(

Wasm.Performance.Driver (1)

Program.cs (1)

93using var registration = runCancellationToken.Token.Register(async () =>