WatchAsync

21 references to WatchAsync

Aspire.Hosting (4)

ApplicationModel\ResourceNotificationService.cs (2)

128await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 420await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

59await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))

ResourceBuilderExtensions.cs (1)

1676await foreach (var resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))

Aspire.Hosting.Azure.Tests (1)

AzureBicepProvisionerTests.cs (1)

282await 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 (14)

Orchestrator\ApplicationOrchestratorTests.cs (5)

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())

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)

415await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 484await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))

WithUrlsTests.cs (4)

338await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 374await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 414await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 465await 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))