Eventing

13 references to Eventing

Aspire.Hosting (3)

ConnectionStringBuilderExtensions.cs (2)

92await @evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(r, @evt.Services), ct).ConfigureAwait(false); 102await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)

ExternalServiceBuilderExtensions.cs (1)

168await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(e.Resource, e.Services), ct).ConfigureAwait(false);

Aspire.Hosting.Azure.EntraId (1)

EntraIdResourceExtensions.cs (1)

217await evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, evt.Services), cancellationToken).ConfigureAwait(false);

Aspire.Hosting.MongoDB (2)

ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (2)

126await evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, evt.Services), ct) 131await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(resource, evt.Services), ct)

Aspire.Hosting.OpenAI (2)

OpenAIExtensions.cs (2)

91await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct) 136await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)

Aspire.Hosting.Tests (4)

Orchestrator\ApplicationOrchestratorTests.cs (2)

212Assert.Equal(applicationEventing, initEvent.Eventing); 1141await @event.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, @event.Services), ct);

WithUrlsTests.cs (2)

88await e.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(custom, e.Services), EventDispatchBehavior.BlockingConcurrent, ct); 91await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(custom, e.Services), EventDispatchBehavior.BlockingSequential, ct);

CustomResources.AppHost (1)

TalkingClockResource.cs (1)

60var eventing = @event.Eventing; // Get the eventing service for publishing events.