31 references to WatchAsync
Aspire.Hosting (9)
ApplicationModel\ResourceNotificationService.cs (2)
130
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
451
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
106
var resourceEvents = resourceNotificationService.
WatchAsync
(linkedToken);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
131
var resourceEvents = notificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardEventHandlers.cs (1)
732
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 (19)
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 (5)
54
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
107
await foreach (var item in notificationService.
WatchAsync
(cancellation))
449
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
507
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
543
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))