11 references to Eventing
Aspire.Hosting (3)
ConnectionStringBuilderExtensions.cs (2)
93
await @evt.
Eventing
.PublishAsync(new BeforeResourceStartedEvent(r, @evt.Services), ct).ConfigureAwait(false);
103
await evt.
Eventing
.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
ExternalServiceBuilderExtensions.cs (1)
168
await e.
Eventing
.PublishAsync(new BeforeResourceStartedEvent(e.Resource, e.Services), ct).ConfigureAwait(false);
Aspire.Hosting.GitHub.Models (1)
GitHubModelsExtensions.cs (1)
80
await evt.
Eventing
.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
91
await evt.
Eventing
.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
136
await evt.
Eventing
.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.Tests (4)
Orchestrator\ApplicationOrchestratorTests.cs (2)
166
Assert.Equal(applicationEventing, initEvent.
Eventing
);
1095
await @event.
Eventing
.PublishAsync(new BeforeResourceStartedEvent(resource, @event.Services), ct);
WithUrlsTests.cs (2)
564
await e.
Eventing
.PublishAsync(new ResourceEndpointsAllocatedEvent(custom, e.Services), EventDispatchBehavior.BlockingConcurrent, ct);
567
await e.
Eventing
.PublishAsync(new BeforeResourceStartedEvent(custom, e.Services), EventDispatchBehavior.BlockingSequential, ct);
CustomResources.AppHost (1)
TalkingClockResource.cs (1)
60
var eventing = @event.
Eventing
; // Get the eventing service for publishing events.