8 references to NonBlockingConcurrent
Aspire.Hosting (6)
Backchannel\BackchannelService.cs (2)
51
EventDispatchBehavior.
NonBlockingConcurrent
,
68
EventDispatchBehavior.
NonBlockingConcurrent
,
Dcp\DcpExecutor.cs (1)
815
await _distributedApplicationEventing.PublishAsync(resourceEvent, EventDispatchBehavior.
NonBlockingConcurrent
, cancellationToken).ConfigureAwait(false);
Eventing\DistributedApplicationEventing.cs (2)
28
if (dispatchBehavior == EventDispatchBehavior.BlockingConcurrent || dispatchBehavior == EventDispatchBehavior.
NonBlockingConcurrent
)
37
if (dispatchBehavior == EventDispatchBehavior.
NonBlockingConcurrent
)
Orchestrator\ApplicationOrchestrator.cs (1)
457
await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.
NonBlockingConcurrent
, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
179
await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.
NonBlockingConcurrent
, ct).ConfigureAwait(false);
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
101
await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.
NonBlockingConcurrent
).DefaultTimeout();