1 write to _eventing
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
47_eventing = eventing;
12 references to _eventing
Aspire.Hosting (12)
Orchestrator\ApplicationOrchestrator.cs (12)
58_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated); 59_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 61_eventing.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent); 62_eventing.Subscribe<InitializeResourceEvent>(OnResourceInitialized); 118await _eventing.PublishAsync(afterEndpointsAllocatedEvent, context.CancellationToken).ConfigureAwait(false); 187await _eventing.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false); 333_eventing.Subscribe<ResourceEndpointsAllocatedEvent>(reference, (_, _) => 347_eventing.Subscribe<ConnectionStringAvailableEvent>(reference, (_, _) => 404await _eventing.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false); 498var initializeEvent = new InitializeResourceEvent(resource, _eventing, _loggerService, _notificationService, _serviceProvider); 499await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false); 520await _eventing.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);