140 references to WaitForResourceAsync
Aspire.Hosting (2)
ApplicationModel\CommandsConfigurationExtensions.cs (1)
273var terminalEvent = await resourceNotificationService.WaitForResourceAsync(rebuilderResource.Name,
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)
725var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
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( 2799app.ResourceNotifications.WaitForResourceAsync( 2841app.ResourceNotifications.WaitForResourceAsync( 2888var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2937var firstBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2941var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3583buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3639var workerStartingTask = app.ResourceNotifications.WaitForResourceAsync( 3660var forcedStartingTask = app.ResourceNotifications.WaitForResourceAsync( 3681var buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3691var 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)
101await app.ResourceNotifications.WaitForResourceAsync(mongo.Resource.Name, 107var 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( 133var updatedResourceTask = app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.Tests (79)
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); 298await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 302await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 353await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 356await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 396var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 405await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 548var notStartedResourceEvent = await rns.WaitForResourceAsync( 553var dependentResourceEvent = await rns.WaitForResourceAsync( 577var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 584var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 593await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 597await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 639notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 640dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 662var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 669var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 678await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 685await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1110var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2120rns.WaitForResourceAsync(containerResourceName, e => 2129rns.WaitForResourceAsync(executableResourceName, e => 2165var containerEvent = await rns.WaitForResourceAsync( 2170var 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)
738await resourceNotificationService.WaitForResourceAsync( 796await resourceNotificationService.WaitForResourceAsync( 847await resourceNotificationService.WaitForResourceAsync( 901await resourceNotificationService.WaitForResourceAsync( 909await resourceNotificationService.WaitForResourceAsync( 1096var waitingEvent = await resourceNotificationService.WaitForResourceAsync(
ResourceCommandServiceTests.cs (1)
1753await 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 (8)
388var resourceEvent = await rns.WaitForResourceAsync( 413var resourceEvent = await rns.WaitForResourceAsync( 446var resourceEvent = await rns.WaitForResourceAsync( 672var resourceEvent = await rns.WaitForResourceAsync( 1061var resourceEvent = await rns.WaitForResourceAsync( 1113var resourceEvent = await rns.WaitForResourceAsync( 1128resourceEvent = await rns.WaitForResourceAsync( 1137resourceEvent = 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);