27 references to ResourceReadyEvent
Aspire.Hosting (1)
Health\ResourceHealthCheckService.cs (1)
219var resourceReadyEvent = new ResourceReadyEvent(resource, services);
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
99builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
236builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(resource, async (e, ct) =>
Aspire.Hosting.Redis.Tests (5)
RedisFunctionalTests.cs (5)
159builder1.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 197builder2.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 249builder.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 583builder1.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder1.Resource, (evt, ct) => 626builder2.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder2.Resource, (evt, ct) =>
Aspire.Hosting.Tests (18)
Health\ResourceHealthCheckServiceTests.cs (17)
114var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 115builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 136var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 164var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 308var blockAssert = new TaskCompletionSource<ResourceReadyEvent>(); 309builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 324var @event = await blockAssert.Task.DefaultTimeout(); 388var resourceReadyEventFired = new TaskCompletionSource<ResourceReadyEvent>(); 389builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 448var resourceReadyEventFired = new TaskCompletionSource<ResourceReadyEvent>(); 449builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 495var parentReady = new TaskCompletionSource<ResourceReadyEvent>(); 496builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 504var childReady = new TaskCompletionSource<ResourceReadyEvent>(); 505builder.Eventing.Subscribe<ResourceReadyEvent>(child.Resource, (@event, ct) => 529var parentReadyEvent = await parentReady.Task.DefaultTimeout(); 532var childReadyEvent = await childReady.Task.DefaultTimeout();
WaitForTests.cs (1)
277builder.Eventing.Subscribe<ResourceReadyEvent>(dependency.Resource, (e, ct) => resourceReadyTcs.Task);
Mongo.AppHost (1)
Program.cs (1)
14builder.Eventing.Subscribe<ResourceReadyEvent>(db.Resource, async (@event, ct) =>