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