1 write to _eventing
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
45_eventing = eventing;
10 references to _eventing
Aspire.Hosting (10)
Orchestrator\ApplicationOrchestrator.cs (10)
55_eventing.Subscribe<AfterEndpointsAllocatedEvent>(ProcessResourcesWithoutLifetime); 56_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(PublishInitialResourceUrls); 58_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent); 98await _eventing.PublishAsync(afterEndpointsAllocatedEvent, context.CancellationToken).ConfigureAwait(false); 108await _eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(resource, _serviceProvider), EventDispatchBehavior.NonBlockingConcurrent, context.CancellationToken).ConfigureAwait(false); 167await _eventing.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false); 319await _eventing.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false); 408var initializeEvent = new InitializeResourceEvent(resource, _eventing, _loggerService, _notificationService, _serviceProvider); 409await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false); 430await _eventing.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);