111 references to WaitForResourceAsync
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
153var waitForNonWaitingStateTask = _notificationService.WaitForResourceAsync(
Aspire.Hosting.Browsers.Tests (18)
BrowserLogsBuilderExtensionsTests.cs (18)
708await app.ResourceNotifications.WaitForResourceAsync( 962var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1011await app.ResourceNotifications.WaitForResourceAsync( 1032var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1096await app.ResourceNotifications.WaitForResourceAsync( 1109var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1171var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1224await app.ResourceNotifications.WaitForResourceAsync( 1233var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1284var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1345var initialEvent = await app.ResourceNotifications.WaitForResourceAsync( 1361var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1408var firstRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1444var secondRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1476var firstCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1492var allCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1545await app.ResourceNotifications.WaitForResourceAsync( 1561await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
41var state = await rns.WaitForResourceAsync(
Aspire.Hosting.DevTunnels.Tests (1)
DevTunnelResourceBuilderExtensionsTests.cs (1)
628var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.EntityFrameworkCore (2)
EFCoreOperationExecutor.cs (2)
318await notificationService.WaitForResourceAsync( 345var resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.Maui (2)
Lifecycle\MauiBuildQueueEventSubscriber.cs (2)
290await notificationService.WaitForResourceAsync( 400await notificationService.WaitForResourceAsync(
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.Testing.Tests (2)
DashboardUrlTests.cs (2)
105var runningResourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 133var updatedResourceTask = app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.Tests (76)
Codespaces\CodespacesUrlRewriterTests.cs (1)
80var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (32)
209var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 217await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 225await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 255var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 256var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 277var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 285var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 294await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 298await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 349await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 352await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 392var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 401await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 544var notStartedResourceEvent = await rns.WaitForResourceAsync( 549var dependentResourceEvent = await rns.WaitForResourceAsync( 573var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 580var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 589await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 593await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 635notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 636dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 658var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 665var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 674await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 681await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1106var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2109rns.WaitForResourceAsync(containerResourceName, e => 2118rns.WaitForResourceAsync(executableResourceName, e => 2154var containerEvent = await rns.WaitForResourceAsync( 2159var executableEvent = await rns.WaitForResourceAsync(
ExternalServiceTests.cs (3)
340var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 367var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 394var 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)
690await resourceNotificationService.WaitForResourceAsync( 748await resourceNotificationService.WaitForResourceAsync( 799await resourceNotificationService.WaitForResourceAsync( 853await resourceNotificationService.WaitForResourceAsync( 861await resourceNotificationService.WaitForResourceAsync( 1048var waitingEvent = await resourceNotificationService.WaitForResourceAsync(
ResourceCommandServiceTests.cs (1)
1650await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => KnownResourceStates.BuildableStates.Contains(e.Snapshot.State?.Text), cts.Token).DefaultTimeout(TimeSpan.FromMinutes(2));
ResourceNotificationTests.cs (13)
371var waitingEvent = await notificationService.WaitForResourceAsync( 384var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 419var waitingEvent = await notificationService.WaitForResourceAsync( 437var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 475var waitingEvent = await notificationService.WaitForResourceAsync( 489var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 529var waitingEvent = await notificationService.WaitForResourceAsync( 609await notificationService.WaitForResourceAsync( 680var waitingEvent = await notificationService.WaitForResourceAsync( 719var waitingEvent = await notificationService.WaitForResourceAsync( 751var waitingEvent = await notificationService.WaitForResourceAsync( 764var partialWaitingEvent = await notificationService.WaitForResourceAsync( 855await notificationService.WaitForResourceAsync(
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 (5)
387var resourceEvent = await rns.WaitForResourceAsync( 412var resourceEvent = await rns.WaitForResourceAsync( 445var resourceEvent = await rns.WaitForResourceAsync( 671var resourceEvent = await rns.WaitForResourceAsync( 972var resourceEvent = 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);