2 implementations of Eventing
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
243public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 395public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
28 references to Eventing
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
227builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
216await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.MySql.Tests (1)
AddMySqlTests.cs (1)
384await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
232builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.Tests (24)
Backchannel\AppHostBackchannelTests.cs (3)
23builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 29builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 67builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {
Eventing\DistributedApplicationBuilderEventingTests.cs (17)
23builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 30builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 36var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingSequential); 55builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 62builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 69var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingConcurrent); 87builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 94builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 101await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingConcurrent).DefaultTimeout(); 120builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 129builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 136await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingSequential).DefaultTimeout(); 169Assert.Equal(builder.Eventing, eventing); 207builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) => 232builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 240builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 248builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
OperationModesTests.cs (4)
23builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 52builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 81builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 112builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {