1 implementation of PublishAsync
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
24
public async Task
PublishAsync
<T>(T @event, EventDispatchBehavior dispatchBehavior, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent
10 references to PublishAsync
Aspire.Hosting (4)
Backchannel\BackchannelService.cs (2)
49
await eventing.
PublishAsync
(
66
await eventing.
PublishAsync
(
Dcp\DcpExecutor.cs (1)
786
await _distributedApplicationEventing.
PublishAsync
(resourceEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
Orchestrator\ApplicationOrchestrator.cs (1)
465
await _eventing.
PublishAsync
(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Tests (6)
Eventing\DistributedApplicationBuilderEventingTests.cs (4)
37
var pendingPublish = builder.Eventing.
PublishAsync
(new DummyEvent(), EventDispatchBehavior.BlockingSequential);
70
var pendingPublish = builder.Eventing.
PublishAsync
(new DummyEvent(), EventDispatchBehavior.BlockingConcurrent);
102
await builder.Eventing.
PublishAsync
(new DummyEvent(), EventDispatchBehavior.NonBlockingConcurrent).DefaultTimeout();
137
await builder.Eventing.
PublishAsync
(new DummyEvent(), EventDispatchBehavior.NonBlockingSequential).DefaultTimeout();
WithUrlsTests.cs (2)
423
await e.Eventing.
PublishAsync
(new ResourceEndpointsAllocatedEvent(custom, e.Services), EventDispatchBehavior.BlockingConcurrent, ct);
426
await e.Eventing.
PublishAsync
(new BeforeResourceStartedEvent(custom, e.Services), EventDispatchBehavior.BlockingSequential, ct);