158 references to WaitForResourceAsync
Aspire.Hosting (2)
ApplicationModel\CommandsConfigurationExtensions.cs (1)
282var terminalEvent = await resourceNotificationService.WaitForResourceAsync(rebuilderResource.Name,
Orchestrator\ApplicationOrchestrator.cs (1)
153var waitForNonWaitingStateTask = _notificationService.WaitForResourceAsync(
Aspire.Hosting.Azure.EntraId.Tests (6)
EntraIdInitializationTests.cs (6)
280await notifications.WaitForResourceAsync(entra.Resource.Name, 290var ready = await notifications.WaitForResourceAsync(entra.Resource.Name, 325await notifications.WaitForResourceAsync(entra.Resource.Name, 336var ready = await notifications.WaitForResourceAsync(entra.Resource.Name, 382await notifications.WaitForResourceAsync(entra.Resource.Name, 503var update = await notifications.WaitForResourceAsync(resource.Name,
Aspire.Hosting.Browsers.Tests (18)
BrowserLogsBuilderExtensionsTests.cs (18)
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( 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 (1)
DockerSocketBindMountTests.cs (1)
41var state = await rns.WaitForResourceAsync(
Aspire.Hosting.DevTunnels.Tests (6)
DevTunnelMonitorTests.cs (1)
60await test.App.ResourceNotifications.WaitForResourceAsync(test.Tunnel.Name,
DevTunnelResourceBuilderExtensionsTests.cs (4)
324await app.ResourceNotifications.WaitForResourceAsync(port.Name, 388await app.ResourceNotifications.WaitForResourceAsync(port.Name, 820var completed = await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name, 842var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
TestDevTunnelMonitor.cs (1)
87await App.ResourceNotifications.WaitForResourceAsync(Port.Name,
Aspire.Hosting.Dotnet (3)
DotnetProjectBuildCoordinator.cs (3)
187var buildEvent = await notificationService.WaitForResourceAsync( 1226await _notificationService.WaitForResourceAsync( 1258await _notificationService.WaitForResourceAsync(
Aspire.Hosting.Dotnet.Tests (12)
DotnetProjectBuildCoordinatorTests.cs (12)
586app.ResourceNotifications.WaitForResourceAsync( 592app.ResourceNotifications.WaitForResourceAsync( 2822app.ResourceNotifications.WaitForResourceAsync( 2878app.ResourceNotifications.WaitForResourceAsync( 2925var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2974var firstBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2978var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3683buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3739var workerStartingTask = app.ResourceNotifications.WaitForResourceAsync( 3760var forcedStartingTask = app.ResourceNotifications.WaitForResourceAsync( 3781var buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3791var workerEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.EntityFrameworkCore (2)
EFCoreOperationExecutor.cs (2)
333await notificationService.WaitForResourceAsync( 360var resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.Maui (4)
Lifecycle\MauiBuildQueueEventSubscriber.cs (3)
332await notificationService.WaitForResourceAsync( 403var terminalStateTask = notificationService.WaitForResourceAsync( 558await notificationService.WaitForResourceAsync(
MauiOtlpExtensions.cs (1)
427resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.MongoDB.Tests (2)
SingleMemberReplicaSetFunctionalTests.cs (2)
160await app.ResourceNotifications.WaitForResourceAsync(mongo.Resource.Name, 166var completed = await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name,
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
611var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
588var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
284await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
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(
Aspire.Hosting.Testing.Tests (2)
DashboardUrlTests.cs (2)
105var runningResourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 134var updatedResourceTask = app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.Tests (86)
Codespaces\CodespacesUrlRewriterTests.cs (1)
80var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (32)
263var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 267await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 271await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 275await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 279await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 309var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 310var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 331var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 339var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 352await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 356await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 407await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, startupToken).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 410await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, startupToken).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 451var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 460await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 603var notStartedResourceEvent = await rns.WaitForResourceAsync( 608var dependentResourceEvent = await rns.WaitForResourceAsync( 632var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 639var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 648await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 652await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 694notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 695dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 717var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 724var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 733await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 740await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1165var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2179rns.WaitForResourceAsync(containerResourceName, e => 2188rns.WaitForResourceAsync(executableResourceName, e => 2224var containerEvent = await rns.WaitForResourceAsync( 2229var executableEvent = await rns.WaitForResourceAsync(
ExternalServiceTests.cs (3)
341var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 368var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 395var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (10)
38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 129var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 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();
Orchestrator\ApplicationOrchestratorTests.cs (6)
736await resourceNotificationService.WaitForResourceAsync( 794await resourceNotificationService.WaitForResourceAsync( 845await resourceNotificationService.WaitForResourceAsync( 899await resourceNotificationService.WaitForResourceAsync( 907await resourceNotificationService.WaitForResourceAsync( 1094var waitingEvent = await resourceNotificationService.WaitForResourceAsync(
ResourceCommandServiceTests.cs (4)
1764await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => KnownResourceStates.BuildableStates.Contains(e.Snapshot.State?.Text), cts.Token).DefaultTimeout(TimeSpan.FromMinutes(2)); 1818await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => e.ResourceId == replicaName && e.Snapshot.State?.Text == KnownResourceStates.Finished, finishedCts.Token).DefaultTimeout(TimeSpan.FromMinutes(2)); 1829await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => e.ResourceId == replicaNames[1] && e.Snapshot.State?.Text == KnownResourceStates.Running, restartCts.Token).DefaultTimeout(TimeSpan.FromMinutes(2)); 1844await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => e.ResourceId == replicaNames[1] && e.Snapshot.State?.Text == KnownResourceStates.Running, runningCts.Token).DefaultTimeout(TimeSpan.FromMinutes(2));
ResourceNotificationTests.cs (17)
417var waitingEvent = await notificationService.WaitForResourceAsync( 430var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 521var waitingEvent = await notificationService.WaitForResourceAsync( 539var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 577var waitingEvent = await notificationService.WaitForResourceAsync( 591var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 631var waitingEvent = await notificationService.WaitForResourceAsync( 711await notificationService.WaitForResourceAsync( 782var waitingEvent = await notificationService.WaitForResourceAsync( 821var waitingEvent = await notificationService.WaitForResourceAsync( 853var waitingEvent = await notificationService.WaitForResourceAsync( 866var partialWaitingEvent = await notificationService.WaitForResourceAsync( 957await notificationService.WaitForResourceAsync( 1513var waitTask = notificationService.WaitForResourceAsync(resource.Name, resourceEvent => 1556var waitTask = notificationService.WaitForResourceAsync(resource.Name, resourceEvent => 1577var waitTask = notificationService.WaitForResourceAsync("myResource", _ => true, cts.Token); 1601var waitTask = notificationService.WaitForResourceAsync(resource.Name, _ => throw expectedException);
WithHttpCommandTests.cs (5)
955var startingEvent = await app.ResourceNotifications.WaitForResourceAsync( 968var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1011var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1026var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1067await app.ResourceNotifications.WaitForResourceAsync(
WithUrlsTests.cs (8)
616var resourceEvent = await rns.WaitForResourceAsync( 641var resourceEvent = await rns.WaitForResourceAsync( 674var resourceEvent = await rns.WaitForResourceAsync( 784var resourceEvent = await rns.WaitForResourceAsync( 1117var resourceEvent = await rns.WaitForResourceAsync( 1169var resourceEvent = await rns.WaitForResourceAsync( 1184resourceEvent = await rns.WaitForResourceAsync( 1193resourceEvent = await rns.WaitForResourceAsync(
Aspire.Hosting.TestUtilities (1)
Utils\PersistentContainerTestHelpers.cs (1)
129var resourceEvent = await resourceNotificationService.WaitForResourceAsync(resourceName, evt =>
Aspire.Playground.Tests (1)
Infrastructure\DistributedApplicationExtensions.cs (1)
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)));
Testing.Tests (3)
WaitFailures.cs (3)
117await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => false, cts.Token); 156await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => x.Snapshot.HealthReports.All(x => x.Status.HasValue), cts.Token); 176await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, x => x.Snapshot.HealthStatus == HealthStatus.Healthy, cts.Token);