13 references to EventDispatchBehavior
Aspire.Hosting (9)
Eventing\DistributedApplicationEventing.cs (6)
19
return PublishAsync(@event,
EventDispatchBehavior
.BlockingSequential, cancellationToken);
24
public async Task PublishAsync<T>(T @event,
EventDispatchBehavior
dispatchBehavior, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent
28
if (dispatchBehavior ==
EventDispatchBehavior
.BlockingConcurrent || dispatchBehavior ==
EventDispatchBehavior
.NonBlockingConcurrent)
37
if (dispatchBehavior ==
EventDispatchBehavior
.NonBlockingConcurrent)
53
if (dispatchBehavior ==
EventDispatchBehavior
.NonBlockingSequential)
Eventing\IDistributedApplicationEventing.cs (1)
55
Task PublishAsync<T>(T @event,
EventDispatchBehavior
dispatchBehavior, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent;
Health\ResourceHealthCheckService.cs (2)
57
EventDispatchBehavior
.NonBlockingSequential,
81
EventDispatchBehavior
.NonBlockingSequential,
Aspire.Hosting.Tests (4)
Eventing\DistributedApplicationBuilderEventingTests.cs (4)
36
var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(),
EventDispatchBehavior
.BlockingSequential);
69
var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(),
EventDispatchBehavior
.BlockingConcurrent);
102
await builder.Eventing.PublishAsync(new DummyEvent(),
EventDispatchBehavior
.NonBlockingConcurrent, timeoutCts.Token);
138
await builder.Eventing.PublishAsync(new DummyEvent(),
EventDispatchBehavior
.NonBlockingSequential, timeoutCts.Token);