2 implementations of Eventing
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
245public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 399public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
49 references to Eventing
Aspire.Hosting.Azure.Tests (4)
AzureCosmosDBExtensionsTests.cs (4)
735await builder.Eventing.PublishAsync(beforeStartEvent); 767await builder.Eventing.PublishAsync(beforeStartEvent); 796await builder.Eventing.PublishAsync(beforeStartEvent); 826await builder.Eventing.PublishAsync(beforeStartEvent);
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
217await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.MySql.Tests (1)
AddMySqlTests.cs (1)
384await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
235builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.Redis.Tests (1)
AddRedisTests.cs (1)
835await builder.Eventing.PublishAsync(beforeStartEvent);
Aspire.Hosting.Tests (39)
Backchannel\AppHostBackchannelTests.cs (3)
24builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 30builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 68builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {
Backchannel\AuxiliaryBackchannelTests.cs (2)
26builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 63builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>
Cli\CliOrphanDetectorTests.cs (1)
245builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
ContainerRegistryResourceTests.cs (12)
523await builder.Eventing.PublishAsync(beforeStartEvent); 544await builder.Eventing.PublishAsync(beforeStartEvent); 568await builder.Eventing.PublishAsync(beforeStartEvent); 590await builder.Eventing.PublishAsync(beforeStartEvent); 613await builder.Eventing.PublishAsync(beforeStartEvent); 649await builder.Eventing.PublishAsync(beforeStartEvent); 673await builder.Eventing.PublishAsync(beforeStartEvent); 703await builder.Eventing.PublishAsync(beforeStartEvent); 724await builder.Eventing.PublishAsync(beforeStartEvent); 744await builder.Eventing.PublishAsync(beforeStartEvent); 765await builder.Eventing.PublishAsync(beforeStartEvent); 786await builder.Eventing.PublishAsync(beforeStartEvent);
Eventing\DistributedApplicationBuilderEventingTests.cs (17)
24builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 31builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 37var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingSequential); 56builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 63builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 70var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingConcurrent); 88builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 95builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 102await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingConcurrent).DefaultTimeout(); 121builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 130builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 137await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingSequential).DefaultTimeout(); 170Assert.Equal(builder.Eventing, eventing); 208builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) => 233builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 241builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 249builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
OperationModesTests.cs (4)
24builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 53builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 82builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 113builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {
Aspire.Hosting.Yarp.Tests (2)
AddYarpTests.cs (2)
421await builder.Eventing.PublishAsync(beforeStartEvent); 446await builder.Eventing.PublishAsync(beforeStartEvent);