41 references to WatchAsync
Aspire.Hosting (11)
ApplicationModel\CommandsConfigurationExtensions.cs (1)
278
await foreach (var evt in resourceNotificationService.
WatchAsync
(buildTimeoutCts.Token).ConfigureAwait(false))
ApplicationModel\ResourceNotificationService.cs (1)
672
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
121
var resourceEvents = resourceNotificationService.
WatchAsync
(linkedToken);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)
757
await foreach (var resourceEvent in notificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
1031
var resourceEvents = notificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardEventHandlers.cs (1)
910
await foreach (var notification in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
96
await foreach (var @event in resourceNotificationService.
WatchAsync
().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
26
var resourceEvents = resourceNotificationService.
WatchAsync
(stoppingToken);
Health\ResourceHealthCheckService.cs (1)
26
var resourceEvents = resourceNotificationService.
WatchAsync
(stoppingToken);
Lifecycle\TerminalHostFailureDiagnosticService.cs (1)
59
await foreach (var evt in notifications.
WatchAsync
(stoppingToken).ConfigureAwait(false))
ResourceLoggerForwarderService.cs (1)
42
await foreach (var resourceEvent in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
76
await foreach (var resourceEvent in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Blazor (2)
BlazorGatewayExtensions.cs (1)
424
await foreach (var resourceEvent in notificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
BrowserDebuggerHelper.cs (1)
300
await foreach (var evt in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Maui (1)
Lifecycle\MauiBuildQueueEventSubscriber.cs (1)
271
/// <see cref="ResourceNotificationService.
WatchAsync
"/> does not immediately satisfy it.
Aspire.Hosting.Maui.Tests (3)
MauiBuildQueueTests.cs (3)
127
await foreach (var evt in env.NotificationService.
WatchAsync
(cts.Token))
161
await foreach (var evt in env.NotificationService.
WatchAsync
(cts.Token))
789
await foreach (var evt in env.NotificationService.
WatchAsync
(cts.Token))
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (20)
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (2)
250
await foreach (var evt in notifications.
WatchAsync
(CancellationToken.None))
261
await foreach (var evt in notifications.
WatchAsync
(CancellationToken.None))
Orchestrator\ApplicationOrchestratorTests.cs (8)
49
await foreach (var item in resourceNotificationService.
WatchAsync
())
97
await foreach (var item in resourceNotificationService.
WatchAsync
())
197
await foreach (var item in resourceNotificationService.
WatchAsync
())
263
await foreach (var item in resourceNotificationService.
WatchAsync
())
315
await foreach (var item in resourceNotificationService.
WatchAsync
())
1405
await foreach (var item in resourceNotificationService.
WatchAsync
())
1462
await foreach (var item in resourceNotificationService.
WatchAsync
())
1516
await foreach (var item in resourceNotificationService.
WatchAsync
())
Orchestrator\ParameterProcessorTests.cs (2)
89
await foreach (var resourceEvent in notificationService.
WatchAsync
().ConfigureAwait(false))
198
var updates = notificationService.
WatchAsync
().GetAsyncEnumerator();
ResourceNotificationTests.cs (6)
80
await foreach (var item in notificationService.
WatchAsync
(cts.Token))
106
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
184
await foreach (var item in notificationService.
WatchAsync
(cancellation))
1042
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
1100
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
1136
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
WithUrlsTests.cs (2)
478
await foreach (var notification in rns.
WatchAsync
().DefaultTimeout(TestConstants.LongTimeoutDuration))
594
await foreach (var notification in rns.
WatchAsync
().DefaultTimeout(TestConstants.LongTimeoutDuration))
Aspire.Hosting.TestUtilities (1)
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))