WatchAsync

54 references to WatchAsync

Aspire.Hosting (10)

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\AppHostRpcTarget.cs (1)

121var 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)

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

Dashboard\DashboardServiceData.cs (1)

96await 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.Tests (1)

AzureBicepProvisionerTests.cs (1)

73await 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)

94await foreach (var item in resourceNotificationService.WatchAsync()) 142await foreach (var item in resourceNotificationService.WatchAsync()) 242await foreach (var item in resourceNotificationService.WatchAsync()) 308await foreach (var item in resourceNotificationService.WatchAsync()) 360await foreach (var item in resourceNotificationService.WatchAsync()) 1452await foreach (var item in resourceNotificationService.WatchAsync()) 1509await foreach (var item in resourceNotificationService.WatchAsync()) 1563await 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(); 1930var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 1966await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2120var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2144var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2172var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2195await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2226await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2260await using var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2313var updates = notificationService.WatchAsync().GetAsyncEnumerator(); 2347var 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)) 1088await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1146await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1182await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1564await foreach (var resourceEvent in notificationService.WatchAsync())

WithUrlsTests.cs (2)

498await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 614await 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))