1 write to ResourceNotifications
Aspire.Hosting (1)
DistributedApplication.cs (1)
89ResourceNotifications = host.Services.GetRequiredService<ResourceNotificationService>();
436 references to ResourceNotifications
Aspire.Hosting (1)
DistributedApplication.cs (1)
849app.ResourceNotifications.TryGetCurrentState(instanceName, out var resourceEvent);
Aspire.Hosting.Azure.Tests (23)
AzureCosmosDBEmulatorFunctionalTests.cs (5)
48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 54await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 94await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
AzureEventHubsExtensionsTests.cs (6)
48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 53await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 78await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 130await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token);
AzureServiceBusExtensionsTests.cs (6)
99await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 101await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 105await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 107await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 1179await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 1180await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (4)
60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 65await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureWebPubSubEmulatorFunctionalTests.cs (1)
30await app.ResourceNotifications.WaitForResourceHealthyAsync(webPubSub.Resource.Name, readyCts.Token);
FoundryExtensionsTests.cs (1)
359app.ResourceNotifications
Aspire.Hosting.Blazor.Tests (2)
AddBlazorGatewayTests.cs (2)
222await app.ResourceNotifications.WaitForResourceAsync("client-publish", KnownResourceStates.Running, timeout.Token); 318await app.ResourceNotifications.WaitForResourceHealthyAsync("gateway", startupTimeout.Token);
Aspire.Hosting.Browsers.Tests (19)
BrowserLogsBuilderExtensionsTests.cs (19)
707await app.ResourceNotifications.WaitForResourceAsync( 961var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1010await app.ResourceNotifications.WaitForResourceAsync( 1031var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1095await app.ResourceNotifications.WaitForResourceAsync( 1108var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1170var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1223await app.ResourceNotifications.WaitForResourceAsync( 1232var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1283var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1344var initialEvent = await app.ResourceNotifications.WaitForResourceAsync( 1352await app.ResourceNotifications.PublishUpdateAsync(web.Resource, snapshot => snapshot with 1360var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1407var firstRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1443var secondRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1475var firstCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1491var allCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1544await app.ResourceNotifications.WaitForResourceAsync( 1560await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.Containers.Tests (6)
DockerSocketBindMountTests.cs (1)
37var rns = app.ResourceNotifications;
ResourceFailureLoggingTests.cs (4)
34await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 58await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 82await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, [KnownResourceStates.Exited, KnownResourceStates.FailedToStart], cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
WithDockerfileTests.cs (1)
776await app.ResourceNotifications.WaitForResourceAsync(resourceName, resourceState).WaitAsync(timeout ?? TimeSpan.FromMinutes(3));
Aspire.Hosting.DevTunnels.Tests (22)
DevTunnelMonitorTests.cs (9)
60await test.App.ResourceNotifications.WaitForResourceAsync(test.Tunnel.Name, 155await test.App.ResourceNotifications.WaitForResourceAsync(test.Port.Name, KnownResourceStates.Running).DefaultTimeout(); 183await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 207await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 317async (_, _) => await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 376await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 408await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 539await test.App.ResourceNotifications.PublishUpdateAsync(test.Tunnel, s => s with { State = KnownResourceStates.FailedToStart }); 540await test.App.ResourceNotifications.WaitForResourceAsync(test.Port.Name, KnownResourceStates.Finished).DefaultTimeout();
DevTunnelResourceBuilderExtensionsTests.cs (10)
324await app.ResourceNotifications.WaitForResourceAsync(port.Name, 388await app.ResourceNotifications.WaitForResourceAsync(port.Name, 813await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name, KnownResourceStates.Finished, cts.Token); 822var completed = await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name, 830await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnel.Resource.Name, cts.Token); 844var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 851await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnel.Resource.Name, cts.Token); 857await app.ResourceNotifications.WaitForResourceHealthyAsync(tunnelPort.Name, cts.Token); 861var waitForDependency = app.ResourceNotifications.WaitForDependenciesAsync(dependent.Resource, cts.Token); 889await app.ResourceNotifications.WaitForResourceAsync(port.Name, KnownResourceStates.Running).DefaultTimeout();
TestDevTunnelMonitor.cs (3)
61await App.ResourceNotifications.PublishUpdateAsync(Tunnel, s => s with { State = KnownResourceStates.Running }); 88await App.ResourceNotifications.WaitForResourceAsync(Port.Name, 94Assert.True(App.ResourceNotifications.TryGetCurrentState(resource.Name, out var current));
Aspire.Hosting.Dotnet.Tests (70)
DotnetProjectBuildCoordinatorTests.cs (70)
232await app.ResourceNotifications.PublishUpdateAsync( 249await app.ResourceNotifications.PublishUpdateAsync( 726await app.ResourceNotifications.PublishUpdateAsync( 931app.ResourceNotifications.WaitForResourceAsync( 937app.ResourceNotifications.WaitForResourceAsync( 1713await app.ResourceNotifications.PublishUpdateAsync( 1733await app.ResourceNotifications.PublishUpdateAsync( 1764await app.ResourceNotifications.PublishUpdateAsync( 1804await app.ResourceNotifications.PublishUpdateAsync( 1841await app.ResourceNotifications.PublishUpdateAsync( 1848Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out var stoppedEvent)); 1891await app.ResourceNotifications.PublishUpdateAsync( 1898Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out var firstStoppedEvent)); 1901await app.ResourceNotifications.PublishUpdateAsync( 1915await app.ResourceNotifications.PublishUpdateAsync( 1922Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out var secondStoppedEvent)); 2013await app.ResourceNotifications.PublishUpdateAsync( 2018await app.ResourceNotifications.PublishUpdateAsync( 2054await app.ResourceNotifications.PublishUpdateAsync( 2064await app.ResourceNotifications.PublishUpdateAsync( 2073await app.ResourceNotifications.PublishUpdateAsync( 2077await app.ResourceNotifications.PublishUpdateAsync( 2119await app.ResourceNotifications.PublishUpdateAsync( 2176await app.ResourceNotifications.PublishUpdateAsync( 2184await app.ResourceNotifications.PublishUpdateAsync( 2191await app.ResourceNotifications.PublishUpdateAsync( 2239var buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2276await app.ResourceNotifications.PublishUpdateAsync( 2416await app.ResourceNotifications.PublishUpdateAsync( 2675await app.ResourceNotifications.PublishUpdateAsync( 2775await app.ResourceNotifications.PublishUpdateAsync( 2790await app.ResourceNotifications.PublishUpdateAsync( 2905await app.ResourceNotifications.PublishUpdateAsync( 3036await app.ResourceNotifications.PublishUpdateAsync( 3078await app.ResourceNotifications.PublishUpdateAsync( 3748app.ResourceNotifications.WaitForResourceAsync("api", KnownResourceStates.Finished, completionCts.Token), 3749app.ResourceNotifications.WaitForResourceAsync("worker", KnownResourceStates.Finished, completionCts.Token)); 3806app.ResourceNotifications.WaitForResourceAsync( 3862app.ResourceNotifications.WaitForResourceAsync( 3909var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3914app.ResourceNotifications.WaitForResourceAsync("first", KnownResourceStates.Finished, completionCts.Token), 3915app.ResourceNotifications.WaitForResourceAsync("second", KnownResourceStates.Finished, completionCts.Token)); 3958var firstBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3962var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3966await app.ResourceNotifications.WaitForResourceAsync( 4018app.ResourceNotifications.WaitForResourceAsync("valid", KnownResourceStates.Finished, completionCts.Token), 4019app.ResourceNotifications.WaitForResourceAsync("missing", KnownResourceStates.FailedToStart, completionCts.Token)); 4251Assert.True(app.ResourceNotifications.TryGetCurrentState("persistent-project", out var projectEvent)); 4279await app.ResourceNotifications.PublishUpdateAsync(builds[0], snapshot => snapshot with 4284await app.ResourceNotifications.PublishUpdateAsync(builds[1], snapshot => snapshot with 4377await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4385await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4392await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4399await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4435await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4457await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 4462await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 4470await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 4477await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 4519await app.ResourceNotifications.PublishUpdateAsync(finalBuild, snapshot => snapshot with 4552await app.ResourceNotifications.PublishUpdateAsync( 4578await app.ResourceNotifications.PublishUpdateAsync( 4613await app.ResourceNotifications.WaitForResourceAsync( 4667buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 4673var workerState = await app.ResourceNotifications.WaitForResourceAsync( 4723var workerStartingTask = app.ResourceNotifications.WaitForResourceAsync( 4735await app.ResourceNotifications.PublishUpdateAsync( 4744var forcedStartingTask = app.ResourceNotifications.WaitForResourceAsync( 4765var buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 4775var workerEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.DotnetTool.Tests (6)
DotnetToolFunctionalTests.cs.cs (6)
23await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 24var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 28Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState)); 46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 50Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState));
Aspire.Hosting.EntityFrameworkCore.Tests (6)
EFBuildReadinessTests.cs (5)
51Assert.True(app.ResourceNotifications.TryGetCurrentState(migrations.Resource.Name, out var state)); 80await app.ResourceNotifications.WaitForResourceAsync( 84() => app.ResourceNotifications.WaitForDependenciesAsync(project.Resource, token)); 110await app.ResourceNotifications.WaitForResourceAsync( 118() => app.ResourceNotifications.WaitForDependenciesAsync(project.Resource, token));
TestServices\CoordinatedBuildTestHelpers.cs (1)
21await app.ResourceNotifications.PublishUpdateAsync(
Aspire.Hosting.Garnet.Tests (4)
GarnetFunctionalTests.cs (4)
42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.JavaScript.Tests (5)
BunAppFixture.cs (2)
122App.ResourceNotifications.WaitForResourceHealthyAsync(BunAppBuilder!.Resource.Name, cancellationToken), 123App.ResourceNotifications.WaitForResourceHealthyAsync(BunScriptBuilder!.Resource.Name, cancellationToken));
DenoAppFixture.cs (3)
156App.ResourceNotifications.WaitForResourceHealthyAsync(DenoAppBuilder!.Resource.Name, cancellationToken) 160readinessTasks.Add(App.ResourceNotifications.WaitForResourceAsync( 167readinessTasks.Add(App.ResourceNotifications.WaitForResourceHealthyAsync(
Aspire.Hosting.Kafka.Tests (4)
KafkaFunctionalTests.cs (4)
44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 46await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.MongoDB.Tests (31)
MongoDbFunctionalTests.cs (6)
56await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 58await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 62await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 132await app.ResourceNotifications.WaitForResourceHealthyAsync(mongodb.Resource.Name, cts.Token); 135await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token);
ReplicaSet\MongoDbReplicaSetFunctionalTests.cs (12)
58await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo.Resource.Name, cts.Token); 59await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 95await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 142await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 179await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 221await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 223await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, cts.Token); 224await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo2.Resource.Name, cts.Token); 225await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo3.Resource.Name, cts.Token); 315await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, cts.Token); 383await app.ResourceNotifications.WaitForResourceHealthyAsync(rs.Resource.Name, secondPhaseCts.Token); 454await app.ResourceNotifications.WaitForResourceAsync(rs.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);
SingleMemberReplicaSetFunctionalTests.cs (12)
51await app.ResourceNotifications.WaitForResourceHealthyAsync(database.Resource.Name, ready.Token); 93await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo.Resource.Name, cts.Token); 100await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token); 160await app.ResourceNotifications.WaitForResourceAsync(mongo.Resource.Name, 162await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name, KnownResourceStates.Waiting, ready.Token); 166var completed = await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name, 196var running = await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, ready.Token); 207await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Exited, restart.Token); 209await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Running, restart.Token); 210await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, restart.Token); 217await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Exited, stop.Token); 226await app2.ResourceNotifications.WaitForResourceHealthyAsync(mongo2.Resource.Name, secondReady.Token);
tests\Shared\ContainerReplCommandTestBase.cs (1)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.Token);
Aspire.Hosting.MySql.Tests (9)
MySqlFunctionalTests.cs (8)
51await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 57await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 59await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 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)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.Token);
Aspire.Hosting.Nats.Tests (4)
NatsFunctionalTests.cs (4)
349await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 351await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 355await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 357await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.OpenAI.Tests (8)
OpenAIFunctionalTests.cs (8)
52await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 58await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 60await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 99await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 101await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 105await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 107await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (4)
OracleFunctionalTests.cs (4)
467await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 469await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 473await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 475await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (16)
PostgresFunctionalTests.cs (14)
54await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 63await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 66await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).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); 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);
PostgresReplCommandTests.cs (1)
95await app.ResourceNotifications.PublishUpdateAsync(postgres.Resource, s => s with { State = KnownResourceStates.FailedToStart });
tests\Shared\ContainerReplCommandTestBase.cs (1)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.Token);
Aspire.Hosting.Python.Tests (1)
AddPythonAppTests.cs (1)
116await app.ResourceNotifications.WaitForResourceAsync("pyproj", KnownResourceStates.Finished).WaitAsync(timeout);
Aspire.Hosting.Qdrant.Tests (4)
QdrantFunctionalTests.cs (4)
278await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 280await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 284await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 286await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (4)
RabbitMQFunctionalTests.cs (4)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (14)
RedisFunctionalTests.cs (13)
53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 120var commanderEvent = await app.ResourceNotifications.WaitForResourceAsync( 128var redisEvent = await app.ResourceNotifications.WaitForResourceAsync( 166var redisEvent = await app.ResourceNotifications.WaitForResourceAsync( 178var commanderEvent = await app.ResourceNotifications.WaitForResourceAsync( 184redisEvent = await app.ResourceNotifications.WaitForResourceAsync( 197await app.ResourceNotifications.WaitForResourceAsync( 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)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.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 (11)
SqlServerFunctionalTests.cs (10)
46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 52await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, 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)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.Token);
Aspire.Hosting.Testing (1)
DistributedApplicationHostingTestingExtensions.cs (1)
86await app.ResourceNotifications.WaitForResourceHealthyAsync(
Aspire.Hosting.Testing.Tests (6)
DashboardUrlTests.cs (4)
105var runningResourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 110await app.ResourceNotifications.PublishUpdateAsync( 132var updatedResourceTask = app.ResourceNotifications.WaitForResourceAsync( 137await app.ResourceNotifications.PublishUpdateAsync(
TestingFactoryTests.cs (1)
80await _app.ResourceNotifications.WaitForResourceAsync("mywebapp1").WaitAsync(TimeSpan.FromSeconds(60));
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (124)
Codespaces\CodespacesUrlRewriterTests.cs (2)
95await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 102var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
ContainerTunnelTests.cs (4)
65await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 108await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 148await app.ResourceNotifications.WaitForResourceAsync(c.Resource.Name, KnownResourceStates.Running) 182await app.ResourceNotifications.WaitForResourceAsync(resourceName, KnownResourceStates.Running)
DistributedApplicationTests.cs (2)
2135await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.NotStarted, token) 2137await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.NotStarted, token)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
391await app.ResourceNotifications.WaitForResourceAsync("redis", KnownResourceStates.Running).DefaultTimeout();
ExternalServiceTests.cs (3)
341var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 368var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 395var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (40)
33await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 41await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 46var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 73await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 81await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 93await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 116await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 124await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 129var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 163await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 168await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 178await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 186await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 192await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 229await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout(); 270await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 313await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 317await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout(); 349await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 380await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 442await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 487await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 538await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 546await app.ResourceNotifications.PublishUpdateAsync(child.Resource, s => s with 582await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 590await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 603var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 628await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 636await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 649var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout(); 668await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with
Orchestrator\ApplicationOrchestratorTests.cs (1)
194Assert.True(app.ResourceNotifications.TryGetCurrentState(frontend.Resource.Name, out var state));
ResourceFailureLoggingTests.cs (3)
36await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.Finished, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 59await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 90await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
WaitForTests.cs (56)
34await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 35await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 36await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 109await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 111await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 140await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 142await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 177await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 182await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 218await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 220await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 225await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 245await app.ResourceNotifications.WaitForResourceHealthyAsync( 269await app.ResourceNotifications.WaitForResourceHealthyAsync( 300await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name) 329await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 331await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 336await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 363await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 365await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 370await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 373await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 378await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 410await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 412await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 417await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 420await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 425await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 455await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 460await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 470await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token); 502await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token); 507await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 517await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 557await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token); 562await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 573await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 611await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 616await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 625await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 662await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 665await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test0", s => s with 670await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 673await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test1", s => s with 678await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 715await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 718await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test0", s => s with 723await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 726await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, "test1", s => s with 731await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 764await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 767await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 772await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 970await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 973await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 980await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);
WithHttpCommandTests.cs (12)
627await app.ResourceNotifications.PublishUpdateAsync(serviceA.Resource, s => s with 631await app.ResourceNotifications.WaitForResourceAsync(serviceA.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 950await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 955var startingEvent = await app.ResourceNotifications.WaitForResourceAsync( 962await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 968var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1005await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 1011var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1020await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 1026var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1059await app.ResourceNotifications.PublishUpdateAsync(resource, s => s with 1067await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.TestUtilities (1)
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Valkey.Tests (5)
tests\Shared\ContainerReplCommandTestBase.cs (1)
195await app.ResourceNotifications.WaitForResourceHealthyAsync(resourceName, readiness.Token);
ValkeyFunctionalTests.cs (4)
227await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 229await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 235await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, 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 (3)
Infrastructure\DistributedApplicationExtensions.cs (2)
90return app.ResourceNotifications.WaitForResourceAsync(resourceName, targetState, cancellationToken); 107return Task.WhenAll(applicationModel.Resources.Select(r => app.ResourceNotifications.WaitForResourceAsync(r.Name, r => targetStates?.Contains(r.Snapshot.State?.Text, StringComparer.OrdinalIgnoreCase) is true || r.Snapshot.IsHidden, cancellationToken)));
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Testing.Tests (17)
WaitFailures.cs (17)
34await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, cancellationToken: cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(pwsh.Resource.Name, cancellationToken: cts.Token); 68await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, cancellationToken: cts.Token); 72await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.TerminalStates, cancellationToken: cts.Token); 87await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, "StateThatIsNeverUsed", cts.Token); 102await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, ["States", "That", "Are", "Never", "Used"], cts.Token); 117await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => false, cts.Token); 136await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token); 156await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => x.Snapshot.HealthReports.All(x => x.Status.HasValue), cts.Token); 159await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token); 176await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => x.Snapshot.HealthStatus == HealthStatus.Healthy, cts.Token); 180await app.ResourceNotifications.WaitForResourceHealthyAsync(nginx.Resource.Name, cts.Token); 206await app.ResourceNotifications.WaitForDependenciesAsync(consumer.Resource, cts.Token); 228await app.ResourceNotifications.WaitForResourceAsync(dependency.Resource.Name, cancellationToken: cts.Token); 232await app.ResourceNotifications.WaitForDependenciesAsync(consumer.Resource, cts.Token); 252await app.ResourceNotifications.WaitForResourceAsync(dependency.Resource.Name, cancellationToken: cts.Token); 256await app.ResourceNotifications.WaitForDependenciesAsync(consumer.Resource, cancellationToken: cts.Token);