2 implementations of Eventing
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
245public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 399public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
45 references to Eventing
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
229builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
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)
819await builder.Eventing.PublishAsync(beforeStartEvent);
Aspire.Hosting.Tests (38)
Backchannel\AppHostBackchannelTests.cs (3)
23builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 29builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 67builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {
Backchannel\AuxiliaryBackchannelTests.cs (2)
23builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 63builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>
ContainerRegistryResourceTests.cs (12)
522await builder.Eventing.PublishAsync(beforeStartEvent); 543await builder.Eventing.PublishAsync(beforeStartEvent); 567await builder.Eventing.PublishAsync(beforeStartEvent); 589await builder.Eventing.PublishAsync(beforeStartEvent); 612await builder.Eventing.PublishAsync(beforeStartEvent); 648await builder.Eventing.PublishAsync(beforeStartEvent); 672await builder.Eventing.PublishAsync(beforeStartEvent); 702await builder.Eventing.PublishAsync(beforeStartEvent); 723await builder.Eventing.PublishAsync(beforeStartEvent); 743await builder.Eventing.PublishAsync(beforeStartEvent); 764await builder.Eventing.PublishAsync(beforeStartEvent); 785await builder.Eventing.PublishAsync(beforeStartEvent);
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) => {
Aspire.Hosting.Yarp.Tests (2)
AddYarpTests.cs (2)
421await builder.Eventing.PublishAsync(beforeStartEvent); 446await builder.Eventing.PublishAsync(beforeStartEvent);