2 implementations of Eventing
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
530public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 693public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
93 references to Eventing
Aspire.Hosting.Azure.Tests (6)
AzureCosmosDBExtensionsTests.cs (6)
791await builder.Eventing.PublishAsync(beforeStartEvent); 823await builder.Eventing.PublishAsync(beforeStartEvent); 852await builder.Eventing.PublishAsync(beforeStartEvent); 882await builder.Eventing.PublishAsync(beforeStartEvent); 1122() => builder.Eventing.PublishAsync(new ResourceReadyEvent(cosmos.Resource, app.Services))); 1139await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(cosmos.Resource, app.Services));
Aspire.Hosting.DevTunnels.Tests (2)
DevTunnelResourceBuilderExtensionsTests.cs (2)
224await builder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnel.Resource, app.Services)).DefaultTimeout(); 662await builder.Eventing.PublishAsync(new ResourceReadyEvent(tunnel.Resource, app.Services)).DefaultTimeout();
Aspire.Hosting.Foundry.Tests (1)
HostedAgentExtensionTests.cs (1)
705await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model));
Aspire.Hosting.Java.Tests (16)
AddJavaAppTests.cs (4)
746() => builder.Eventing.PublishAsync( 765() => builder.Eventing.PublishAsync( 792await builder.Eventing.PublishAsync( 853() => builder.Eventing.PublishAsync(
AddQuarkusAppTests.cs (3)
96await builder.Eventing.PublishAsync( 113await builder.Eventing.PublishAsync( 285() => builder.Eventing.PublishAsync(
AddSpringBootAppTests.cs (9)
21await builder.Eventing.PublishAsync( 38await builder.Eventing.PublishAsync( 55await builder.Eventing.PublishAsync( 75await runBuilder.Eventing.PublishAsync( 113await builder.Eventing.PublishAsync( 136await builder.Eventing.PublishAsync( 189() => builder.Eventing.PublishAsync( 210() => runBuilder.Eventing.PublishAsync( 237await builder.Eventing.PublishAsync(
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
217await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.Keycloak.Tests (1)
KeycloakResourceBuilderTests.cs (1)
81await builder.Eventing.PublishAsync(beforeStartEvent);
Aspire.Hosting.Maui.Tests (3)
MauiPlatformExtensionsTests.cs (3)
749appBuilder.Eventing.Subscribe<ResourceEndpointsAllocatedEvent>((evt, _) => 766await appBuilder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()), CancellationToken.None); 770await appBuilder.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(dashboard.Resource, app.Services), CancellationToken.None);
Aspire.Hosting.MySql.Tests (1)
AddMySqlTests.cs (1)
384await appBuilder.Eventing.PublishAsync(
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
237builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
865await builder.Eventing.PublishAsync(beforeStartEvent); 902await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, appModel)); 938await builder.Eventing.PublishAsync(beforeStartEvent);
Aspire.Hosting.Tests (56)
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)
28builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) => 65builder.Eventing.Subscribe<AuxiliaryBackchannelConnectedEvent>((e, ct) =>
Cli\CliOrphanDetectorTests.cs (1)
268builder.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 (22)
27builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 34builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 40var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingSequential); 59builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 66builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 73var pendingPublish = builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.BlockingConcurrent); 91builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 98builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 105await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingConcurrent).DefaultTimeout(); 124builder.Eventing.Subscribe<DummyEvent>(async (@event, ct) => 133builder.Eventing.Subscribe<DummyEvent>((@event, ct) => 140await builder.Eventing.PublishAsync(new DummyEvent(), EventDispatchBehavior.NonBlockingSequential).DefaultTimeout(); 173Assert.Equal(builder.Eventing, eventing); 211builder.Eventing.Subscribe<BeforeResourceStartedEvent>((e, ct) => 236builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 244builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 252builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => 281builder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => Task.CompletedTask); 396builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => 492builder.Eventing.Subscribe<IDistributedApplicationEvent>((_, _) => Task.CompletedTask)); 504builder.Eventing.Subscribe<AbstractDummyEvent>((_, _) => Task.CompletedTask)); 517builder.Eventing.Subscribe<IDistributedApplicationResourceEvent>(resource.Resource, (_, _) => Task.CompletedTask));
OperationModesTests.cs (4)
25builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 54builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 83builder.Eventing.Subscribe<AfterResourcesCreatedEvent>((e, ct) => { 114builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => {
WithOtlpExporterTests.cs (2)
225builder.Eventing.Subscribe<BeforeStartEvent>((e, ct) => 257await builder.Eventing.PublishAsync(beforeStartEvent);
WithTerminalTests.cs (10)
296await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 374await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 462await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 514await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 910await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 926await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 944await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 1274await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 1296await builder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, model)); 1343await cleanupService.SubscribeAsync(builder.Eventing, executionContext, CancellationToken.None);
Aspire.Hosting.Yarp.Tests (2)
AddYarpTests.cs (2)
444await builder.Eventing.PublishAsync(beforeStartEvent); 469await builder.Eventing.PublishAsync(beforeStartEvent);