WatchAsync

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

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

ResourceBuilderExtensions.cs (1)

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

Aspire.Hosting.Azure.Tests (1)

AzureBicepProvisionerTests.cs (1)

283await 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 (13)

Orchestrator\ApplicationOrchestratorTests.cs (4)

40await foreach (var item in resourceNotificationService.WatchAsync()) 92await foreach (var item in resourceNotificationService.WatchAsync()) 157await foreach (var item in resourceNotificationService.WatchAsync()) 209await 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)

371await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 440await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))

WithUrlsTests.cs (4)

309await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 345await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 385await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 436await 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))