WatchAsync

36 references to WatchAsync

Aspire.Hosting (9)

ApplicationModel\ResourceNotificationService.cs (2)

129await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 450await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (1)

71var resourceEvents = resourceNotificationService.WatchAsync(cancellationToken);

Dashboard\DashboardEventHandlers.cs (1)

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

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

Orchestrator\ApplicationOrchestratorTests.cs (9)

44await foreach (var item in resourceNotificationService.WatchAsync()) 91await foreach (var item in resourceNotificationService.WatchAsync()) 189await foreach (var item in resourceNotificationService.WatchAsync()) 254await foreach (var item in resourceNotificationService.WatchAsync()) 305await foreach (var item in resourceNotificationService.WatchAsync()) 420await foreach (var item in resourceNotificationService.WatchAsync()) 690await foreach (var item in resourceNotificationService.WatchAsync()) 746await foreach (var item in resourceNotificationService.WatchAsync()) 799await foreach (var item in resourceNotificationService.WatchAsync())

Orchestrator\ParameterProcessorTests.cs (2)

83await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false)) 188var 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)

331await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 367await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 411await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 500await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 621await 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))