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)

MySqlFunctionalTests.cs (2)

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

PostgresFunctionalTests.cs (2)

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

RedisFunctionalTests.cs (1)

223var latestEvent = await app2.ResourceNotifications.WaitForResourceHealthyAsync(redisInsightBuilder.Resource.Name, cts.Token);

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

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

DistributedApplicationTests.cs (5)

131var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 175var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 176var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 237var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 238var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

Health\ResourceHealthCheckServiceTests.cs (6)

39var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 47var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 79var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 87var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 122var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 130var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource",

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)

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

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

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