WaitForResourceHealthyAsync

Ats\NotificationExports.cs (1)

59var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName).ConfigureAwait(false);

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);

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)

105await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 141await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 1180await 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);

AddBlazorGatewayTests.cs (1)

291await app.ResourceNotifications.WaitForResourceHealthyAsync("gateway", startupTimeout.Token);

DevTunnelResourceBuilderExtensionsTests.cs (3)

787await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnel.Resource.Name, cts.Token); 808await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnel.Resource.Name, cts.Token); 814await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnelPort.Name, cts.Token);

GarnetFunctionalTests.cs (1)

48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);

BunAppFixture.cs (2)

122App.ResourceNotifications.WaitForResourceHealthyAsync(BunAppBuilder!.Resource.Name, cancellationToken), 123App.ResourceNotifications.WaitForResourceHealthyAsync(BunScriptBuilder!.Resource.Name, cancellationToken));

DenoAppFixture.cs (2)

156App.ResourceNotifications.WaitForResourceHealthyAsync(DenoAppBuilder!.Resource.Name, cancellationToken) 167readinessTasks.Add(App.ResourceNotifications.WaitForResourceHealthyAsync(

KafkaFunctionalTests.cs (1)

50await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

MongoDbFunctionalTests.cs (2)

62await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 132await app.ResourceNotifications.WaitForResourceHealthyAsync(mongodb.Resource.Name, cts.Token);

ReplicaSet\MongoDbReplicaSetFunctionalTests.cs (11)

SingleMemberReplicaSetFunctionalTests.cs (5)

51await app.ResourceNotifications.WaitForResourceHealthyAsync(database.Resource.Name, ready.Token); 93await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo.Resource.Name, cts.Token); 196var running = await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, ready.Token); 210await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, restart.Token); 226await app2.ResourceNotifications.WaitForResourceHealthyAsync(mongo2.Resource.Name, secondReady.Token);

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

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);

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

NatsFunctionalTests.cs (1)

355await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);

OpenAIFunctionalTests.cs (2)

49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 96await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);

OracleFunctionalTests.cs (1)

473await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);

PostgresFunctionalTests.cs (12)

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

RabbitMQFunctionalTests.cs (1)

49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

RedisFunctionalTests.cs (4)

59await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 255await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 787await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 788await app.ResourceNotifications.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

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);

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);

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)

36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);

ContainerTunnelTests.cs (2)

39await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 82await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

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 (6)

1321var waitTask = notificationService.WaitForResourceHealthyAsync("myResource"); 1366var waitTask = notificationService.WaitForResourceHealthyAsync("myResource"); 1391var waitTask = notificationService.WaitForResourceHealthyAsync("myResource"); 1584var waitTask = notificationService.WaitForResourceHealthyAsync(resource.Name); 1606var waitTask = notificationService.WaitForResourceHealthyAsync(resource.Name); 1642() => notificationService.WaitForResourceHealthyAsync(resource.Name));

WaitForTests.cs (1)

299await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name)

Utils\LoggerNotificationExtensions.cs (1)

36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);

Utils\PersistentContainerTestHelpers.cs (1)

128await resourceNotificationService.WaitForResourceHealthyAsync(resourceName, cancellationToken);

tests\Shared\ContainerReplCommandTestBase.cs (1)

165await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Name, readiness.Token);

ValkeyFunctionalTests.cs (1)

233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);

YarpFunctionalTests.cs (2)

54await app.ResourceNotifications.WaitForResourceHealthyAsync(backend.Resource.Name, cts.Token); 55await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name, cts.Token);

tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)

36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken);

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);

Program.cs (1)

102await notifications.WaitForResourceHealthyAsync("redis1");