ResourceEvent

ApplicationModel\ResourceNotificationService.cs (2)

463yield return new ResourceEvent(resource, resourceId, snapshot); 517OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));

ApplicationModel\ResourceNotificationService.cs (18)

29private Action<ResourceEvent>? OnResourceUpdated { get; set; } 128await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 161var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 241public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 274public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 277var resourceEvent = await WaitForResourceCoreAsync(resourceName, re => ShouldYield(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 323var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 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)) 437public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 439var channel = Channel.CreateUnbounded<ResourceEvent>(); 441void WriteToChannel(ResourceEvent resourceEvent) => 469await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (1)

59await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardLifecycleHook.cs (1)

369await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

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

Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)

28await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false))

Health\ResourceHealthCheckService.cs (8)

29await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false)) 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)

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

ResourceLoggerForwarderService.cs (1)

42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

AzureBicepProvisionerTests.cs (1)

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

DockerSocketBindMountTests.cs (1)

41var state = await rns.WaitForResourceAsync(

MySqlFunctionalTests.cs (1)

598var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>

PostgresFunctionalTests.cs (1)

579var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>

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

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

Codespaces\CodespacesUrlRewriterTests.cs (1)

81var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(

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