13 instantiations of OnResourceStartingContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (5)
1006await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1219await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1225await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1236await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1248await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (8)
Orchestrator\ApplicationOrchestratorTests.cs (8)
441await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 568await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 638var startingTask = events.PublishAsync(new OnResourceStartingContext( 687var startingTask = events.PublishAsync(new OnResourceStartingContext( 745var startingTask = events.PublishAsync(new OnResourceStartingContext( 796var startingTask = events.PublishAsync(new OnResourceStartingContext( 850var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 858var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext(
14 references to OnResourceStartingContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
72dcpExecutorEvents.Subscribe<OnResourceStartingContext>(OnResourceStarting); 236private async Task OnResourceStarting(OnResourceStartingContext context)
Aspire.Hosting.Tests (12)
Dcp\DcpExecutorTests.cs (12)
131var startingEvents = new List<OnResourceStartingContext>(); 133events.Subscribe<OnResourceStartingContext>((context) => 156var e = Assert.Single(startingEvents); 3779events.Subscribe<OnResourceStartingContext>(context => 3783observedEvents.Enqueue(nameof(OnResourceStartingContext)); 3812eventName => Assert.Equal(nameof(OnResourceStartingContext), eventName)); 3906events.Subscribe<OnResourceStartingContext>(async context => 3952events.Subscribe<OnResourceStartingContext>(async context => 9060events.Subscribe<OnResourceStartingContext>(context => 9337events.Subscribe<OnResourceStartingContext>(context => 9415events.Subscribe<OnResourceStartingContext>(async context => 9476events.Subscribe<OnResourceStartingContext>(async context =>