2 implementations of Eventing
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
219public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 356public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
51 references to Eventing
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
108builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => {
Aspire.Hosting.PostgreSQL.Tests (1)
AddPostgresTests.cs (1)
381await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
231builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.Tests (48)
Backchannel\AppHostBackchannelTests.cs (4)
25builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 31builder.Eventing.Subscribe<BackchannelConnectedEvent>((e, ct) => { 61builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => { 104builder.Eventing.Subscribe<BackchannelReadyEvent>((e, ct) => {
Eventing\DistributedApplicationBuilderEventingTests.cs (18)
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); 182builder.Eventing.Subscribe<BeforeResourceStartedEvent>(redis.Resource, (e, ct) => 209builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) => 234builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 241builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 248builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) =>
Health\ResourceHealthCheckServiceTests.cs (6)
152builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 341builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 419builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 478builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 523builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 532builder.Eventing.Subscribe<ResourceReadyEvent>(child.Resource, (@event, 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) => {
WaitForTests.cs (1)
539builder.Eventing.Subscribe<ResourceReadyEvent>(dependency.Resource, (e, ct) => resourceReadyTcs.Task);
WithUrlsTests.cs (15)
56builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 62builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 88builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 143builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 168builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 194builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 223builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 247builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 271builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 302builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 508builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 538builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 566builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 597builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) => 628builder.Eventing.Subscribe<BeforeResourceStartedEvent>(projectA.Resource, (e, ct) =>