27 references to ResourceReadyEvent
Aspire.Hosting (1)
Health\ResourceHealthCheckService.cs (1)
247var resourceReadyEvent = new ResourceReadyEvent(resource, services);
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
103builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
247builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(resource, async (e, ct) =>
Aspire.Hosting.Redis.Tests (5)
RedisFunctionalTests.cs (5)
158builder1.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 196builder2.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 247builder.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder.Resource, (evt, ct) => 579builder1.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder1.Resource, (evt, ct) => 622builder2.Eventing.Subscribe<ResourceReadyEvent>(redisInsightBuilder2.Resource, (evt, ct) =>
Aspire.Hosting.Tests (18)
Health\ResourceHealthCheckServiceTests.cs (17)
152var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 153builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 173var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 201var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 341var blockAssert = new TaskCompletionSource<ResourceReadyEvent>(); 342builder.Eventing.Subscribe<ResourceReadyEvent>(resource.Resource, (@event, ct) => 356var @event = await blockAssert.Task.DefaultTimeout(); 419var resourceReadyEventFired = new TaskCompletionSource<ResourceReadyEvent>(); 420builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 478var resourceReadyEventFired = new TaskCompletionSource<ResourceReadyEvent>(); 479builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 523var parentReady = new TaskCompletionSource<ResourceReadyEvent>(); 524builder.Eventing.Subscribe<ResourceReadyEvent>(parent.Resource, (@event, ct) => 532var childReady = new TaskCompletionSource<ResourceReadyEvent>(); 533builder.Eventing.Subscribe<ResourceReadyEvent>(child.Resource, (@event, ct) => 556var parentReadyEvent = await parentReady.Task.DefaultTimeout(); 559var childReadyEvent = await childReady.Task.DefaultTimeout();
WaitForTests.cs (1)
540builder.Eventing.Subscribe<ResourceReadyEvent>(dependency.Resource, (e, ct) => resourceReadyTcs.Task);
Mongo.AppHost (1)
Program.cs (1)
14builder.Eventing.Subscribe<ResourceReadyEvent>(db.Resource, async (@event, ct) =>