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);
118
await
_eventing
.PublishAsync(afterEndpointsAllocatedEvent, context.CancellationToken).ConfigureAwait(false);
187
await
_eventing
.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false);
333
_eventing
.Subscribe<ResourceEndpointsAllocatedEvent>(reference, (_, _) =>
347
_eventing
.Subscribe<ConnectionStringAvailableEvent>(reference, (_, _) =>
404
await
_eventing
.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false);
498
var initializeEvent = new InitializeResourceEvent(resource,
_eventing
, _loggerService, _notificationService, _serviceProvider);
499
await
_eventing
.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
520
await
_eventing
.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);