1 write to _eventing
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
46_eventing = eventing;
9 references to _eventing
Aspire.Hosting (9)
Orchestrator\ApplicationOrchestrator.cs (9)
57_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated); 58_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 60_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent); 116await _eventing.PublishAsync(afterEndpointsAllocatedEvent, context.CancellationToken).ConfigureAwait(false); 185await _eventing.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false); 339await _eventing.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false); 433var initializeEvent = new InitializeResourceEvent(resource, _eventing, _loggerService, _notificationService, _serviceProvider); 434await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false); 455await _eventing.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);