23 references to EventDispatchBehavior
Aspire.Hosting (13)
Backchannel\AuxiliaryBackchannelService.cs (1)
153EventDispatchBehavior.NonBlockingConcurrent,
Backchannel\BackchannelService.cs (2)
69EventDispatchBehavior.NonBlockingConcurrent, 94EventDispatchBehavior.NonBlockingConcurrent,
Dcp\DcpExecutor.cs (1)
1379await _distributedApplicationEventing.PublishAsync(ev, EventDispatchBehavior.BlockingSequential, ct).ConfigureAwait(false);
Eventing\DistributedApplicationEventing.cs (7)
20return PublishAsync(@event, EventDispatchBehavior.BlockingSequential, cancellationToken); 25public async Task PublishAsync<T>(T @event, EventDispatchBehavior dispatchBehavior, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent 29if (dispatchBehavior == EventDispatchBehavior.BlockingConcurrent || dispatchBehavior == EventDispatchBehavior.NonBlockingConcurrent) 38if (dispatchBehavior == EventDispatchBehavior.NonBlockingConcurrent) 54if (dispatchBehavior == EventDispatchBehavior.NonBlockingSequential) 80EventDispatchBehavior dispatchBehavior,
Eventing\IDistributedApplicationEventing.cs (1)
56Task PublishAsync<T>(T @event, EventDispatchBehavior dispatchBehavior, CancellationToken cancellationToken = default) where T : IDistributedApplicationEvent;
Orchestrator\ApplicationOrchestrator.cs (1)
740await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
221await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false); 708await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, services), EventDispatchBehavior.NonBlockingSequential, ct).ConfigureAwait(false);
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
219EventDispatchBehavior.BlockingSequential);
Aspire.Hosting.MySql.Tests (1)
AddMySqlTests.cs (1)
386EventDispatchBehavior.BlockingSequential);
Aspire.Hosting.Tests (6)
Eventing\DistributedApplicationBuilderEventingTests.cs (4)
40var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingSequential); 73var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingConcurrent); 105await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingConcurrent).DefaultTimeout(); 140await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingSequential).DefaultTimeout();
WithUrlsTests.cs (2)
564await e.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(custom, e.Services), EventDispatchBehavior.BlockingConcurrent, ct); 567await e.Eventing.PublishAsync(new BeforeResourceStartedEvent(custom, e.Services), EventDispatchBehavior.BlockingSequential, ct);