6 instantiations of OnResourceFailedToStartContext
Aspire.Hosting (4)
Dcp\DcpExecutor.cs (4)
1068await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1105await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1110await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1322await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false);
Aspire.Hosting.Tests (2)
Orchestrator\ApplicationOrchestratorTests.cs (2)
1061await events.PublishAsync(new OnResourceFailedToStartContext( 1090await events.PublishAsync(new OnResourceFailedToStartContext(
29 references to OnResourceFailedToStartContext
Aspire.Hosting (2)
Orchestrator\ApplicationOrchestrator.cs (2)
75dcpExecutorEvents.Subscribe<OnResourceFailedToStartContext>(OnResourceFailedToStart); 670private async Task OnResourceFailedToStart(OnResourceFailedToStartContext context)
Aspire.Hosting.Tests (27)
Dcp\DcpExecutorTests.cs (27)
4967var tcs = new TaskCompletionSource<OnResourceFailedToStartContext>(TaskCreationOptions.RunContinuationsAsynchronously); 4968dcpEvents.Subscribe<OnResourceFailedToStartContext>(c => 4988var failedContext = await tcs.Task.DefaultTimeout(); 5951events.Subscribe<OnResourceFailedToStartContext>(context => 6456var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 6458events.Subscribe<OnResourceFailedToStartContext>(context => 6485var failure = Assert.Single(failures); 7530events.Subscribe<OnResourceFailedToStartContext>(context => 8452events.Subscribe<OnResourceFailedToStartContext>(context => 8968events.Subscribe<OnResourceFailedToStartContext>(context => 9300events.Subscribe<OnResourceFailedToStartContext>(context => 9470events.Subscribe<OnResourceFailedToStartContext>(context => 9546events.Subscribe<OnResourceFailedToStartContext>(context => 9741events.Subscribe<OnResourceFailedToStartContext>(context => 9959events.Subscribe<OnResourceFailedToStartContext>(context => 10590var failures = new List<OnResourceFailedToStartContext>(); 10592events.Subscribe<OnResourceFailedToStartContext>(context => 10606var failure = Assert.Single(failures); 10658var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 10660events.Subscribe<OnResourceFailedToStartContext>(context => 10673var failure = Assert.Single(failures); 10836var failures = new ConcurrentQueue<OnResourceFailedToStartContext>(); 10838events.Subscribe<OnResourceFailedToStartContext>(context => 11036events.Subscribe<OnResourceFailedToStartContext>(c => 11073events.Subscribe<OnResourceFailedToStartContext>(c => 11154events.Subscribe<OnResourceFailedToStartContext>(context => 11245events.Subscribe<OnResourceFailedToStartContext>(context =>