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)

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

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

AzureBicepProvisionerTests.cs (1)

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

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

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

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