WatchAsync

55 references to WatchAsync

Aspire.Hosting (10)

ApplicationModel\ResourceNotificationService.cs (1)

732await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (1)

123var resourceEvents = resourceNotificationService.WatchAsync(linkedToken);

Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)

779await foreach (var resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false)) 1053var resourceEvents = notificationService.WatchAsync(cancellationToken);

Dashboard\DashboardEventHandlers.cs (1)

781await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

97await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))

Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)

26var resourceEvents = resourceNotificationService.WatchAsync(stoppingToken);

Health\ResourceHealthCheckService.cs (1)

26var resourceEvents = resourceNotificationService.WatchAsync(stoppingToken);

Lifecycle\TerminalHostFailureDiagnosticService.cs (1)

59await foreach (var evt in notifications.WatchAsync(stoppingToken).ConfigureAwait(false))

ResourceLoggerForwarderService.cs (1)

42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Aspire.Hosting.Azure.EntraId (1)

EntraIdResourceExtensions.cs (1)

110await foreach (var update in evt.Notifications.WatchAsync(cancellationToken).ConfigureAwait(false))

Aspire.Hosting.Azure.Tests (1)

AzureBicepProvisionerTests.cs (1)

106await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))

Aspire.Hosting.Blazor (2)

BlazorGatewayExtensions.cs (1)

512await foreach (var resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

BrowserDebuggerHelper.cs (1)

300await foreach (var evt in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Aspire.Hosting.DevTunnels (1)

DevTunnelMonitor.cs (1)

434await foreach (var update in _notifications.WatchAsync(run.Cancellation.Token).ConfigureAwait(false))

Aspire.Hosting.Maui (1)

Lifecycle\MauiBuildQueueEventSubscriber.cs (1)

306/// <see cref="ResourceNotificationService.WatchAsync"/> does not immediately satisfy it.

Aspire.Hosting.Maui.Tests (3)

MauiBuildQueueTests.cs (3)

129await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 163await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 1163await foreach (var evt in env.NotificationService.WatchAsync(cts.Token))

Aspire.Hosting.MongoDB (1)

MongoDBSingleMemberReplicaSet.cs (1)

40await foreach (var update in evt.Notifications.WatchAsync(stopping.Token).ConfigureAwait(false))

Aspire.Hosting.Testing.Tests (1)

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

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))

Aspire.Hosting.Tests (32)

Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (2)

250await foreach (var evt in notifications.WatchAsync(CancellationToken.None)) 261await foreach (var evt in notifications.WatchAsync(CancellationToken.None))

Orchestrator\ApplicationOrchestratorTests.cs (8)

95await foreach (var item in resourceNotificationService.WatchAsync()) 143await foreach (var item in resourceNotificationService.WatchAsync()) 243await foreach (var item in resourceNotificationService.WatchAsync()) 309await foreach (var item in resourceNotificationService.WatchAsync()) 361await foreach (var item in resourceNotificationService.WatchAsync()) 1454await foreach (var item in resourceNotificationService.WatchAsync()) 1511await foreach (var item in resourceNotificationService.WatchAsync()) 1565await foreach (var item in resourceNotificationService.WatchAsync())

Orchestrator\ParameterProcessorTests.cs (13)

88await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false)) 134var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 275var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2064var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2100await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2254var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2278var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2306var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2329await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2360await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2394await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2447var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2481var updates = notificationService.WatchAsync().GetAsyncEnumerator();

ResourceNotificationTests.cs (7)

80await foreach (var item in notificationService.WatchAsync(cts.Token)) 106await foreach (var item in notificationService.WatchAsync(cancellationToken)) 184await foreach (var item in notificationService.WatchAsync(cancellation)) 1144await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1202await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1238await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1620await foreach (var resourceEvent in notificationService.WatchAsync())

WithUrlsTests.cs (2)

118await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 707await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration))

Aspire.Hosting.TestUtilities (1)

Utils\LoggerNotificationExtensions.cs (1)

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))

Aspire.Playground.Tests (1)

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

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))