ResourceEvent

ApplicationModel\ResourceNotificationService.cs (15)

29private Action<ResourceEvent>? OnResourceUpdated { get; set; } 128await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 241public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 274public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 402/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 407public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 410var resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false); 416private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 420await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 439public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 441var channel = Channel.CreateUnbounded<ResourceEvent>(); 443void WriteToChannel(ResourceEvent resourceEvent) => 471await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

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

Health\ResourceHealthCheckService.cs (7)

128ResourceEvent? currentEvent = null; 311public ResourceMonitorState(ILogger logger, ResourceEvent initialEvent, CancellationToken serviceStoppingToken) 324public ResourceEvent LatestEvent { get; private set; } 332public void SetLatestEvent(ResourceEvent resourceEvent) 348internal async Task<bool> DelayAsync(ResourceEvent? currentEvent, TimeSpan delay, CancellationToken cancellationToken) 371private static bool ShouldInterrupt(ResourceEvent currentEvent, ResourceEvent previousEvent)

ResourceBuilderExtensions.cs (1)

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

AzureBicepProvisionerTests.cs (1)

283await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))

MySqlFunctionalTests.cs (2)

500var resourceEvent = await rns.WaitForResourceHealthyAsync("resource", cts.Token); 519static string? GetContainerId(ResourceEvent resourceEvent)

PostgresFunctionalTests.cs (2)

485var resourceEvent = await rns.WaitForResourceHealthyAsync("resource", cts.Token); 499static string? GetContainerId(ResourceEvent resourceEvent)

tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)

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

DistributedApplicationTests.cs (9)

Health\ResourceHealthCheckServiceTests.cs (12)

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

51async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 53var values = new List<ResourceEvent>(); 55await foreach (var item in notificationService.WatchAsync(cancellationToken)) 104async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 106var values = new List<ResourceEvent>(); 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))

tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)

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