WatchAsync

36 references to WatchAsync

Aspire.Hosting (9)

ApplicationModel\ResourceNotificationService.cs (2)

130await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 451await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (1)

71var resourceEvents = resourceNotificationService.WatchAsync(cancellationToken);

Dashboard\DashboardEventHandlers.cs (1)

726await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

68await 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)

2159await 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)

68await 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 (24)

Orchestrator\ApplicationOrchestratorTests.cs (9)

46await foreach (var item in resourceNotificationService.WatchAsync()) 93await foreach (var item in resourceNotificationService.WatchAsync()) 191await foreach (var item in resourceNotificationService.WatchAsync()) 256await foreach (var item in resourceNotificationService.WatchAsync()) 307await foreach (var item in resourceNotificationService.WatchAsync()) 422await foreach (var item in resourceNotificationService.WatchAsync()) 695await foreach (var item in resourceNotificationService.WatchAsync()) 751await foreach (var item in resourceNotificationService.WatchAsync()) 804await foreach (var item in resourceNotificationService.WatchAsync())

Orchestrator\ParameterProcessorTests.cs (2)

82await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false)) 187var updates = notificationService.WatchAsync().GetAsyncEnumerator();

ResourceNotificationTests.cs (5)

54await foreach (var item in notificationService.WatchAsync(cancellationToken)) 107await foreach (var item in notificationService.WatchAsync(cancellation)) 449await foreach (var item in notificationService.WatchAsync(cancellationToken)) 507await foreach (var item in notificationService.WatchAsync(cancellationToken)) 543await foreach (var item in notificationService.WatchAsync(cancellationToken))

Utils\LoggerNotificationExtensions.cs (1)

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))

WithHttpCommandTests.cs (2)

384await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 454await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))

WithUrlsTests.cs (5)

385await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 421await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 465await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 554await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 675await 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))