1 implementation of Subscribe
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
106public DistributedApplicationEventSubscription Subscribe<T>(IResource resource, Func<T, CancellationToken, Task> callback) where T : IDistributedApplicationResourceEvent
50 references to Subscribe
Aspire.Hosting (1)
ResourceBuilderExtensions.cs (1)
1326builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, (@event, ct) =>
Aspire.Hosting.Azure.CosmosDB (2)
AzureCosmosDBExtensions.cs (2)
92builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(builder.Resource, async (@event, ct) => 104builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Azure.Storage (4)
AzureStorageExtensions.cs (4)
135builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, async (@event, ct) => 145builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(builder.Resource, async (@event, ct) => 298builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 332builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) =>
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
112builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
41builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) =>
Aspire.Hosting.MongoDB (2)
MongoDBBuilderExtensions.cs (2)
62builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBContainer, async (@event, ct) => 113builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (3)
MySqlBuilderExtensions.cs (3)
43builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 53builder.Eventing.Subscribe<ResourceReadyEvent>(resource, async (@event, ct) => 109builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) =>
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
60builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
43builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (3)
PostgresBuilderExtensions.cs (3)
56builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 66builder.Eventing.Subscribe<ResourceReadyEvent>(postgresServer, async (@event, ct) => 152builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) =>
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
52builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
45builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
74builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) =>
Aspire.Hosting.SqlServer (3)
SqlServerBuilderExtensions.cs (3)
48builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(sqlServer, async (@event, ct) => 58builder.Eventing.Subscribe<ResourceReadyEvent>(sqlServer, async (@event, ct) => 115builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(sqlServerDatabase, async (@event, ct) =>
Aspire.Hosting.Tests (22)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
182builder.Eventing.Subscribe<BeforeResourceStartedEvent>(redis.Resource, (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) =>
WaitForTests.cs (1)
539builder.Eventing.Subscribe<ResourceReadyEvent>(dependency.Resource, (e, ct) => resourceReadyTcs.Task);
WithUrlsTests.cs (14)
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) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
125builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>
CustomResources.AppHost (1)
TalkingClockResource.cs (1)
32builder.Eventing.Subscribe<InitializeResourceEvent>(clockResource, static async (@event, token) =>
Mongo.AppHost (1)
Program.cs (1)
14builder.Eventing.Subscribe<ResourceReadyEvent>(db.Resource, async (@event, ct) =>