1 write to _eventing
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
52
_eventing
= eventing;
10 references to _eventing
Aspire.Hosting (10)
Orchestrator\ApplicationOrchestrator.cs (10)
63
_eventing
.Subscribe<ResourceEndpointsAllocatedEvent>(OnResourceEndpointsAllocated);
64
_eventing
.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue);
66
_eventing
.Subscribe<BeforeResourceStartedEvent>(WaitForInBeforeResourceStartedEvent);
122
await
_eventing
.PublishAsync(afterEndpointsAllocatedEvent, context.CancellationToken).ConfigureAwait(false);
191
await
_eventing
.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false);
366
await
_eventing
.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false);
466
var initializeEvent = new InitializeResourceEvent(resource,
_eventing
, _loggerService, _notificationService, _serviceProvider);
467
await
_eventing
.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
488
await
_eventing
.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);
512
await
_eventing
.PublishAsync(createEvent(resource), cancellationToken).ConfigureAwait(false);