92 references to WaitForResourceHealthyAsync
Aspire.Hosting (1)
Ats\NotificationExports.cs (1)
59var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName).ConfigureAwait(false);
Aspire.Hosting.Azure.Kusto.Tests (6)
KustoFunctionalTests.cs (6)
56await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cancellationToken: cts.Token); 109await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cancellationToken: cts.Token); 189await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 217await rns.WaitForResourceHealthyAsync(kusto.Resource.Name, cts.Token); 220await rns.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 258await rns.WaitForResourceHealthyAsync(kustoDb.Resource.Name, cts.Token);
Aspire.Hosting.Azure.Tests (20)
AzureCosmosDBEmulatorFunctionalTests.cs (5)
54await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 94await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 175await rns.WaitForResourceHealthyAsync(cosmos1.Resource.Name, cts.Token); 223await rns.WaitForResourceHealthyAsync(cosmos2.Resource.Name, cts.Token); 293await rns.WaitForResourceHealthyAsync(cosmos.Resource.Name, cts.Token);
AzureEventHubsExtensionsTests.cs (3)
53await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 78await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 130await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token);
AzureServiceBusExtensionsTests.cs (3)
104await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 140await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 849await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (1)
65await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token);
AzureStorageEmulatorFunctionalTests.cs (8)
57await rns.WaitForResourceHealthyAsync(blobs.Resource.Name, cts.Token); 58await rns.WaitForResourceHealthyAsync(queues.Resource.Name, cts.Token); 59await rns.WaitForResourceHealthyAsync(tables.Resource.Name, cts.Token); 102await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cts.Token); 145await rns.WaitForResourceHealthyAsync(testQueue.Resource.Name, cts.Token); 193await rns.WaitForResourceHealthyAsync(storage.Resource.Name, cts.Token); 225await rns.WaitForResourceHealthyAsync(blobContainer.Resource.Name, cancellationToken: cts.Token); 265await rns.WaitForResourceHealthyAsync(queue.Resource.Name, cancellationToken: cts.Token);
Aspire.Hosting.Garnet.Tests (1)
GarnetFunctionalTests.cs (1)
48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.GitHub.Models.Tests (1)
GitHubModelsFunctionalTests.cs (1)
47await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.JavaScript.Tests (2)
BunAppFixture.cs (2)
122App.ResourceNotifications.WaitForResourceHealthyAsync(BunAppBuilder!.Resource.Name, cancellationToken), 123App.ResourceNotifications.WaitForResourceHealthyAsync(BunScriptBuilder!.Resource.Name, cancellationToken));
Aspire.Hosting.Kafka.Tests (1)
KafkaFunctionalTests.cs (1)
50await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.MongoDB.Tests (1)
MongoDbFunctionalTests.cs (1)
60await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.MySql.Tests (6)
MySqlFunctionalTests.cs (6)
57await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 610await rns.WaitForResourceHealthyAsync(resourceName, cancellationToken); 672await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 755await app.ResourceNotifications.WaitForResourceHealthyAsync(mysql.Resource.Name, cts.Token); 817await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 856await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
Aspire.Hosting.Nats.Tests (1)
NatsFunctionalTests.cs (1)
355await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.OpenAI.Tests (2)
OpenAIFunctionalTests.cs (2)
49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 96await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.Oracle.Tests (1)
OracleFunctionalTests.cs (1)
473await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (12)
PostgresFunctionalTests.cs (12)
63await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 130await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 169await app.ResourceNotifications.WaitForResourceHealthyAsync(pgWebBuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 235await app.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 298await app.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 419await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 503await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 587await rns.WaitForResourceHealthyAsync(resourceName, cancellationToken); 630await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 679await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 749await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 811await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (1)
RabbitMQFunctionalTests.cs (1)
49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (4)
RedisFunctionalTests.cs (4)
59await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 148await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 680await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 681await app.ResourceNotifications.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);
Aspire.Hosting.Seq.Tests (3)
SeqFunctionalTests.cs (3)
37await app.ResourceNotifications.WaitForResourceHealthyAsync(seq.Resource.Name, default); 117await app.ResourceNotifications.WaitForResourceHealthyAsync(seq1.Resource.Name, default); 156await app.ResourceNotifications.WaitForResourceHealthyAsync(seq2.Resource.Name, default);
Aspire.Hosting.SqlServer.Tests (7)
SqlServerFunctionalTests.cs (7)
52await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 182await app1.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 268await app2.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 382await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 443await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 516await app.ResourceNotifications.WaitForResourceHealthyAsync(sqlserver.Resource.Name, cts.Token); 579await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);
Aspire.Hosting.Tests (11)
Health\ResourceHealthCheckServiceTests.cs (6)
46var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 93await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 168await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 192await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout(); 603var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
HealthCheckTests.cs (1)
143await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
ResourceNotificationTests.cs (3)
1275var waitTask = notificationService.WaitForResourceHealthyAsync("myResource"); 1320var waitTask = notificationService.WaitForResourceHealthyAsync("myResource"); 1345var waitTask = notificationService.WaitForResourceHealthyAsync("myResource");
WaitForTests.cs (1)
299await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name)
Aspire.Hosting.TestUtilities (2)
Utils\LoggerNotificationExtensions.cs (1)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);
Utils\PersistentContainerTestHelpers.cs (1)
128await resourceNotificationService.WaitForResourceHealthyAsync(resourceName, cancellationToken);
Aspire.Hosting.Valkey.Tests (1)
ValkeyFunctionalTests.cs (1)
233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
Aspire.Hosting.Yarp.Tests (2)
YarpFunctionalTests.cs (2)
54await app.ResourceNotifications.WaitForResourceHealthyAsync(backend.Resource.Name, cts.Token); 55await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name, cts.Token);
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);
Testing.Tests (3)
WaitFailures.cs (3)
136await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token); 159await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token); 180await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token);
TestingAppHost1.AppHost (1)
Program.cs (1)
102await notifications.WaitForResourceHealthyAsync("redis1");