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)
58
EventDispatchBehavior
.NonBlockingSequential,
82
EventDispatchBehavior
.NonBlockingSequential,
Aspire.Hosting.Tests (4)
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();