Eventing

13 references to Eventing

Aspire.Hosting (3)

ConnectionStringBuilderExtensions.cs (2)

93await @evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(r, @evt.Services), ct).ConfigureAwait(false); 103await 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)

131await 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)

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

WithUrlsTests.cs (2)

584await e.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(custom, e.Services), EventDispatchBehavior.BlockingConcurrent, ct); 587await 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.