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)
102
var resourceEvents = resourceNotificationService.
WatchAsync
(linkedToken);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
394
var resourceEvents = notificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardEventHandlers.cs (1)
769
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)
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
())
432
await foreach (var item in resourceNotificationService.
WatchAsync
())
718
await foreach (var item in resourceNotificationService.
WatchAsync
())
775
await foreach (var item in resourceNotificationService.
WatchAsync
())
829
await foreach (var item in resourceNotificationService.
WatchAsync
())
Orchestrator\ParameterProcessorTests.cs (2)
86
await foreach (var resourceEvent in notificationService.
WatchAsync
().ConfigureAwait(false))
195
var updates = notificationService.
WatchAsync
().GetAsyncEnumerator();
ResourceNotificationTests.cs (6)
72
await foreach (var item in notificationService.
WatchAsync
(cts.Token))
98
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
151
await foreach (var item in notificationService.
WatchAsync
(cancellation))
493
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
551
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
587
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)
479
await foreach (var notification in rns.
WatchAsync
(cts.Token))
597
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))