13 instantiations of OnResourceStartingContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (5)
1045await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1258await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1264await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1275await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1287await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (8)
Orchestrator\ApplicationOrchestratorTests.cs (8)
486await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 613await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 683var startingTask = events.PublishAsync(new OnResourceStartingContext( 732var startingTask = events.PublishAsync(new OnResourceStartingContext( 790var startingTask = events.PublishAsync(new OnResourceStartingContext( 841var startingTask = events.PublishAsync(new OnResourceStartingContext( 895var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 903var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext(
16 references to OnResourceStartingContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
72dcpExecutorEvents.Subscribe<OnResourceStartingContext>(OnResourceStarting); 234private async Task OnResourceStarting(OnResourceStartingContext context)
Aspire.Hosting.Tests (14)
Dcp\DcpExecutorTests.cs (14)
286var startingEvents = new ConcurrentQueue<OnResourceStartingContext>(); 288events.Subscribe<OnResourceStartingContext>(context => 483var startingEvents = new List<OnResourceStartingContext>(); 485events.Subscribe<OnResourceStartingContext>((context) => 508var e = Assert.Single(startingEvents); 4498events.Subscribe<OnResourceStartingContext>(context => 4502observedEvents.Enqueue(nameof(OnResourceStartingContext)); 4531eventName => Assert.Equal(nameof(OnResourceStartingContext), eventName)); 4625events.Subscribe<OnResourceStartingContext>(async context => 4671events.Subscribe<OnResourceStartingContext>(async context => 9837events.Subscribe<OnResourceStartingContext>(context => 10114events.Subscribe<OnResourceStartingContext>(context => 10698events.Subscribe<OnResourceStartingContext>(async context => 10759events.Subscribe<OnResourceStartingContext>(async context =>