13 instantiations of OnResourceStartingContext
Aspire.Hosting (5)
Dcp\DcpExecutor.cs (5)
1059await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1272await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1278await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1289await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1301await _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); 3886events.Subscribe<OnResourceStartingContext>(context => 3890observedEvents.Enqueue(nameof(OnResourceStartingContext)); 3919eventName => Assert.Equal(nameof(OnResourceStartingContext), eventName)); 4013events.Subscribe<OnResourceStartingContext>(async context => 4059events.Subscribe<OnResourceStartingContext>(async context => 9167events.Subscribe<OnResourceStartingContext>(context => 9444events.Subscribe<OnResourceStartingContext>(context => 9522events.Subscribe<OnResourceStartingContext>(async context => 9583events.Subscribe<OnResourceStartingContext>(async context =>