6 instantiations of OnResourceFailedToStartContext
Aspire.Hosting (4)
Dcp\DcpExecutor.cs (4)
1056await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1093await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1098await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1307await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false);
Aspire.Hosting.Tests (2)
Orchestrator\ApplicationOrchestratorTests.cs (2)
556await events.PublishAsync(new OnResourceFailedToStartContext( 585await events.PublishAsync(new OnResourceFailedToStartContext(
29 references to OnResourceFailedToStartContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
74dcpExecutorEvents.Subscribe<OnResourceFailedToStartContext>(OnResourceFailedToStart); 603private async Task OnResourceFailedToStart(OnResourceFailedToStartContext context)
Aspire.Hosting.Tests (27)
Dcp\DcpExecutorTests.cs (27)
4845var tcs = new TaskCompletionSource<OnResourceFailedToStartContext>(TaskCreationOptions.RunContinuationsAsynchronously); 4846dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 4866var failedContext = await tcs.Task.DefaultTimeout(); 5750events.Subscribe<OnResourceFailedToStartContext>(context => 6255var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 6257events.Subscribe<OnResourceFailedToStartContext>(context => 6284var failure = Assert.Single(failures); 7329events.Subscribe<OnResourceFailedToStartContext>(context => 8251events.Subscribe<OnResourceFailedToStartContext>(context => 8767events.Subscribe<OnResourceFailedToStartContext>(context => 9099events.Subscribe<OnResourceFailedToStartContext>(context => 9269events.Subscribe<OnResourceFailedToStartContext>(context => 9345events.Subscribe<OnResourceFailedToStartContext>(context => 9540events.Subscribe<OnResourceFailedToStartContext>(context => 9753events.Subscribe<OnResourceFailedToStartContext>(context => 10384var failures = new List<OnResourceFailedToStartContext>(); 10386events.Subscribe<OnResourceFailedToStartContext>(context => 10400var failure = Assert.Single(failures); 10452var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 10454events.Subscribe<OnResourceFailedToStartContext>(context => 10467var failure = Assert.Single(failures); 10630var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 10632events.Subscribe<OnResourceFailedToStartContext>(context => 10830events.Subscribe<OnResourceFailedToStartContext>(c => 10867events.Subscribe<OnResourceFailedToStartContext>(c => 10948events.Subscribe<OnResourceFailedToStartContext>(context => 11039events.Subscribe<OnResourceFailedToStartContext>(context =>