8 instantiations of OnResourceChangedContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (3)
981await _executorEvents.PublishAsync(new OnResourceChangedContext( 999await _executorEvents.PublishAsync(new OnResourceChangedContext( 1020await _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)
66Task PublishStateAsync(string? state, string? previousState) => events.PublishAsync(new OnResourceChangedContext( 1353await events.PublishAsync(new OnResourceChangedContext( 1401await events.PublishAsync(new OnResourceChangedContext(
24 references to OnResourceChangedContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
70dcpExecutorEvents.Subscribe<OnResourceChangedContext>(OnResourceChanged); 578private async Task OnResourceChanged(OnResourceChangedContext context)
Aspire.Hosting.Tests (22)
Dcp\DcpExecutorTests.cs (22)
62events.Subscribe<OnResourceChangedContext>(async context => 129events.Subscribe<OnResourceChangedContext>(context => 225events.Subscribe<OnResourceChangedContext>(context => 492events.Subscribe<OnResourceChangedContext>(async (context) => 2133events.Subscribe<OnResourceChangedContext>(context => 2292events.Subscribe<OnResourceChangedContext>(context => 2381events.Subscribe<OnResourceChangedContext>(context => 2742events.Subscribe<OnResourceChangedContext>(context => 2898events.Subscribe<OnResourceChangedContext>(context => 3008var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3010events.Subscribe<OnResourceChangedContext>(context => 3064var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3076var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3078events.Subscribe<OnResourceChangedContext>(context => 3106var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3130events.Subscribe<OnResourceChangedContext>(context => 3183events.Subscribe<OnResourceChangedContext>(context => 3239events.Subscribe<OnResourceChangedContext>(context => 3335events.Subscribe<OnResourceChangedContext>(context => 3457events.Subscribe<OnResourceChangedContext>(context => 3529events.Subscribe<OnResourceChangedContext>(context => 3609events.Subscribe<OnResourceChangedContext>(context =>