27 references to WatchAsync
Aspire.Hosting (9)
ApplicationModel\ResourceNotificationService.cs (2)
129await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 421await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
71var resourceEvents = resourceNotificationService.WatchAsync(cancellationToken);
Dashboard\DashboardLifecycleHook.cs (1)
369await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
66await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
26var resourceEvents = resourceNotificationService.WatchAsync(stoppingToken);
Health\ResourceHealthCheckService.cs (1)
26var resourceEvents = resourceNotificationService.WatchAsync(stoppingToken);
ResourceBuilderExtensions.cs (1)
1706await foreach (var resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))
ResourceLoggerForwarderService.cs (1)
42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
64await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (15)
Orchestrator\ApplicationOrchestratorTests.cs (6)
39await foreach (var item in resourceNotificationService.WatchAsync()) 86await foreach (var item in resourceNotificationService.WatchAsync()) 177await foreach (var item in resourceNotificationService.WatchAsync()) 242await foreach (var item in resourceNotificationService.WatchAsync()) 293await foreach (var item in resourceNotificationService.WatchAsync()) 408await foreach (var item in resourceNotificationService.WatchAsync())
ResourceNotificationTests.cs (2)
55await foreach (var item in notificationService.WatchAsync(cancellationToken)) 108await foreach (var item in notificationService.WatchAsync(cancellation))
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (2)
385await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 455await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
WithUrlsTests.cs (4)
339await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 375await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 463await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 584await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))