32 references to WatchAsync
Aspire.Hosting (9)
ApplicationModel\ResourceNotificationService.cs (2)
129
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
443
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
71
var resourceEvents = resourceNotificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardLifecycleHook.cs (1)
438
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);
ResourceBuilderExtensions.cs (1)
1898
await foreach (var resourceEvent in rns.
WatchAsync
(ct).WithCancellation(ct))
ResourceLoggerForwarderService.cs (1)
42
await foreach (var resourceEvent in resourceNotificationService.
WatchAsync
(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
64
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 (6)
39
await foreach (var item in resourceNotificationService.
WatchAsync
())
86
await foreach (var item in resourceNotificationService.
WatchAsync
())
184
await foreach (var item in resourceNotificationService.
WatchAsync
())
249
await foreach (var item in resourceNotificationService.
WatchAsync
())
300
await foreach (var item in resourceNotificationService.
WatchAsync
())
415
await foreach (var item in resourceNotificationService.
WatchAsync
())
Orchestrator\ParameterProcessorTests.cs (2)
80
await foreach (var resourceEvent in notificationService.
WatchAsync
().ConfigureAwait(false))
185
var updates = notificationService.
WatchAsync
().GetAsyncEnumerator();
ResourceNotificationTests.cs (4)
54
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
107
await foreach (var item in notificationService.
WatchAsync
(cancellation))
448
await foreach (var item in notificationService.
WatchAsync
(cancellationToken))
505
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))
WithHttpCommandTests.cs (2)
384
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(watchCts.Token).WithCancellation(watchCts.Token))
454
await foreach (var resourceEvent in app.ResourceNotifications.
WatchAsync
(watchCts.Token).WithCancellation(watchCts.Token))
WithUrlsTests.cs (5)
331
await foreach (var notification in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
367
await foreach (var notification in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
411
await foreach (var notification in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
500
await foreach (var notification in rns.
WatchAsync
(cts.Token).WithCancellation(cts.Token))
621
await foreach (var notification in rns.
WatchAsync
(cts.Token).WithCancellation(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))