1 implementation of Subscribe
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
159public DistributedApplicationEventSubscription Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent
34 references to Subscribe
Aspire.Hosting (4)
Dashboard\DashboardEventHandlers.cs (2)
226eventing.Subscribe<BeforeResourceStartedEvent>(dashboardResource, (@event, _) => 347eventing.Subscribe<ResourceReadyEvent>(dashboardResource, DashboardStarted);
DistributedApplicationEventingExtensions.cs (1)
141builder.ApplicationBuilder.Eventing.Subscribe<TEvent>(builder.Resource, (evt, ct) => callback(builder.Resource, evt, ct));
ExternalServiceBuilderExtensions.cs (1)
124builder.Eventing.Subscribe<InitializeResourceEvent>(resource, static async (e, ct) =>
Aspire.Hosting.Blazor (1)
BlazorGatewayExtensions.cs (1)
498gateway.ApplicationBuilder.Eventing.Subscribe<InitializeResourceEvent>(gateway.Resource, (e, ct) =>
Aspire.Hosting.DevTunnels.Tests (4)
DevTunnelMonitorTests.cs (4)
113test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, async (_, ct) => 256test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, 696test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, async (_, ct) => 717test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, (_, _) =>
Aspire.Hosting.Dotnet (3)
DotnetProjectBuildCoordinator.cs (3)
140var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>( 166var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>( 772var subscription = builder.Eventing.Subscribe<BeforeResourceStartedEvent>(
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
395builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(foundryResource, (@event, ct) =>
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
116builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (2)
KafkaBuilderExtensions.cs (2)
44builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) => 135builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(kafkaUi, (e, ct) =>
Aspire.Hosting.MongoDB (1)
MongoDBBuilderExtensions.cs (1)
274builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (4)
MySqlBuilderExtensions.cs (4)
49builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 59builder.Eventing.Subscribe<ResourceReadyEvent>(resource, async (@event, ct) => 179builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) => 329builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(phpMyAdminContainer, async (e, ct) =>
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
64builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
45builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (3)
PostgresBuilderExtensions.cs (3)
66builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 76builder.Eventing.Subscribe<ResourceReadyEvent>(postgresServer, async (@event, ct) => 208builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) =>
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
56builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
237builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
47builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (2)
RedisBuilderExtensions.cs (2)
83builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) => 302builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(resource, async (e, ct) =>
Aspire.Hosting.Tests (2)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
517builder.Eventing.Subscribe<IDistributedApplicationResourceEvent>(resource.Resource, (_, _) => Task.CompletedTask));
Orchestrator\ApplicationOrchestratorTests.cs (1)
191applicationEventing.Subscribe<InitializeResourceEvent>(resource.Resource, (@event, ct) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
132builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>