8 instantiations of OnResourceChangedContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (3)
993await _executorEvents.PublishAsync(new OnResourceChangedContext( 1011await _executorEvents.PublishAsync(new OnResourceChangedContext( 1032await _executorEvents.PublishAsync(new OnResourceChangedContext(
Dcp\DcpResourceWatcher.cs (2)
401publishTask = _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceType, appModelResource, resource.Metadata.Name, status, 1020publishTask = _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceKind, appModelResource, resourceName, status, status.State, s =>
Aspire.Hosting.Tests (3)
Orchestrator\ApplicationOrchestratorTests.cs (3)
571Task PublishStateAsync(string? state, string? previousState) => events.PublishAsync(new OnResourceChangedContext( 1859await events.PublishAsync(new OnResourceChangedContext( 1907await events.PublishAsync(new OnResourceChangedContext(
24 references to OnResourceChangedContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
71dcpExecutorEvents.Subscribe<OnResourceChangedContext>(OnResourceChanged); 645private async Task OnResourceChanged(OnResourceChangedContext context)
Aspire.Hosting.Tests (22)
Dcp\DcpExecutorTests.cs (22)
64events.Subscribe<OnResourceChangedContext>(async context => 131events.Subscribe<OnResourceChangedContext>(context => 227events.Subscribe<OnResourceChangedContext>(context => 494events.Subscribe<OnResourceChangedContext>(async (context) => 2135events.Subscribe<OnResourceChangedContext>(context => 2294events.Subscribe<OnResourceChangedContext>(context => 2383events.Subscribe<OnResourceChangedContext>(context => 2744events.Subscribe<OnResourceChangedContext>(context => 2900events.Subscribe<OnResourceChangedContext>(context => 3010var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3012events.Subscribe<OnResourceChangedContext>(context => 3066var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3078var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3080events.Subscribe<OnResourceChangedContext>(context => 3108var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3132events.Subscribe<OnResourceChangedContext>(context => 3185events.Subscribe<OnResourceChangedContext>(context => 3241events.Subscribe<OnResourceChangedContext>(context => 3337events.Subscribe<OnResourceChangedContext>(context => 3459events.Subscribe<OnResourceChangedContext>(context => 3531events.Subscribe<OnResourceChangedContext>(context => 3611events.Subscribe<OnResourceChangedContext>(context =>