13 instantiations of OnResourceStartingContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (5)
1057await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1273await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1279await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1290await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1302await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (8)
Orchestrator\ApplicationOrchestratorTests.cs (8)
991await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 1118await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 1188var startingTask = events.PublishAsync(new OnResourceStartingContext( 1237var startingTask = events.PublishAsync(new OnResourceStartingContext( 1295var startingTask = events.PublishAsync(new OnResourceStartingContext( 1346var startingTask = events.PublishAsync(new OnResourceStartingContext( 1400var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 1408var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext(
16 references to OnResourceStartingContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
73dcpExecutorEvents.Subscribe<OnResourceStartingContext>(OnResourceStarting); 249private async Task OnResourceStarting(OnResourceStartingContext context)
Aspire.Hosting.Tests (14)
Dcp\DcpExecutorTests.cs (14)
288var startingEvents = new ConcurrentQueue<OnResourceStartingContext>(); 290events.Subscribe<OnResourceStartingContext>(context => 485var startingEvents = new List<OnResourceStartingContext>(); 487events.Subscribe<OnResourceStartingContext>((context) => 510var e = Assert.Single(startingEvents); 4500events.Subscribe<OnResourceStartingContext>(context => 4504observedEvents.Enqueue(nameof(OnResourceStartingContext)); 4537eventName => Assert.Equal(nameof(OnResourceStartingContext), eventName)); 4631events.Subscribe<OnResourceStartingContext>(async context => 4677events.Subscribe<OnResourceStartingContext>(async context => 10043events.Subscribe<OnResourceStartingContext>(context => 10320events.Subscribe<OnResourceStartingContext>(context => 10904events.Subscribe<OnResourceStartingContext>(async context => 10965events.Subscribe<OnResourceStartingContext>(async context =>