32 references to WatchAsync
Aspire.Hosting (9)
ApplicationModel\ResourceNotificationService.cs (2)
129
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
450
await foreach (var resourceEvent in
WatchAsync
(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
71
var resourceEvents = resourceNotificationService.
WatchAsync
(cancellationToken);
Dashboard\DashboardLifecycleHook.cs (1)
687
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)
1933
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)
41
await foreach (var item in resourceNotificationService.
WatchAsync
())
88
await foreach (var item in resourceNotificationService.
WatchAsync
())
186
await foreach (var item in resourceNotificationService.
WatchAsync
())
251
await foreach (var item in resourceNotificationService.
WatchAsync
())
302
await foreach (var item in resourceNotificationService.
WatchAsync
())
417
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))