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.GitHub.Models (1)

GitHubModelsExtensions.cs (1)

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

Aspire.Hosting.MongoDB (2)

ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (2)

134await evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, evt.Services), ct) 139await 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)

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

WithUrlsTests.cs (2)

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