31 references to WatchAsync
Aspire.Hosting (8)
ApplicationModel\ResourceNotificationService.cs (1)
476
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
96
var resourceEvents = resourceNotificationService.
WatchAsync
(linkedToken);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
484
var resourceEvents = notificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardEventHandlers.cs (1)
797
await foreach (var notification in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
68
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);
ResourceLoggerForwarderService.cs (1)
42
await foreach (var resourceEvent in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
69
await foreach (var resourceEvent in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (20)
Orchestrator\ApplicationOrchestratorTests.cs (9)
50
await foreach (var item in resourceNotificationService.
WatchAsync
())
98
await foreach (var item in resourceNotificationService.
WatchAsync
())
198
await foreach (var item in resourceNotificationService.
WatchAsync
())
264
await foreach (var item in resourceNotificationService.
WatchAsync
())
316
await foreach (var item in resourceNotificationService.
WatchAsync
())
433
await foreach (var item in resourceNotificationService.
WatchAsync
())
719
await foreach (var item in resourceNotificationService.
WatchAsync
())
776
await foreach (var item in resourceNotificationService.
WatchAsync
())
830
await foreach (var item in resourceNotificationService.
WatchAsync
())
Orchestrator\ParameterProcessorTests.cs (2)
87
await foreach (var resourceEvent in notificationService.
WatchAsync
().ConfigureAwait(false))
196
var updates = notificationService.
WatchAsync
().GetAsyncEnumerator();
ResourceNotificationTests.cs (6)
73
await foreach (var item in notificationService.
WatchAsync
(cts.Token))
99
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
152
await foreach (var item in notificationService.
WatchAsync
(cancellation))
494
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
552
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
588
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))
WithUrlsTests.cs (2)
480
await foreach (var notification in rns.
WatchAsync
(cts.Token))
598
await foreach (var notification in rns.
WatchAsync
(cts.Token))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(cancellationTokenSource.Token).ConfigureAwait(false))