4 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
482resourceEvent = new ResourceEvent(state.Resource, resourceId, snapshot); 505resourceEvent = new ResourceEvent(m.Value.Resource, m.Key, m.Value.LastSnapshot); 543yield return new ResourceEvent(state.Value.Resource, resourceId, snapshot); 603OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));
101 references to ResourceEvent
Aspire.Hosting (37)
ApplicationModel\ResourceCommandService.cs (1)
47if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent))
ApplicationModel\ResourceNotificationService.cs (21)
30private Action<ResourceEvent>? OnResourceUpdated { get; set; } 129await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 185public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 218public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 221var resourceEvent = await WaitForResourceCoreAsync(resourceName, re => ShouldYield(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 267var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 303Func<ILogger, string, string, ResourceEvent, Task> postRunningAction, CancellationToken cancellationToken) 322var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 425/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 430public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 433var resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false); 439private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 443await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 473/// <param name="resourceEvent">When this method returns, contains the <see cref="ResourceEvent"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param> 475public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out ResourceEvent? resourceEvent) 517public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 519var channel = Channel.CreateUnbounded<ResourceEvent>(); 521void WriteToChannel(ResourceEvent resourceEvent) => 549await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
73await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardLifecycleHook.cs (1)
438await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
68await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
28await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false))
Exec\ExecResourceManager.cs (1)
127if (!_resourceNotificationService.TryGetCurrentState(dcpExecResourceName, out var resourceEvent))
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)
1898await foreach (var resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))
ResourceLoggerForwarderService.cs (1)
42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
64await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
40var state = await rns.WaitForResourceAsync(
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
599var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
578var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
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 (58)
Codespaces\CodespacesUrlRewriterTests.cs (1)
79var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (13)
133var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 177var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 178var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 199var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 207var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 252var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 253var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 273var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 280var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 328ResourceEvent? notStartedResourceEvent = null; 329ResourceEvent? dependentResourceEvent = null; 356var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 363var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
ExternalServiceTests.cs (3)
297var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 324var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 351var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
37var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 45var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 77var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 85var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 120var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 128var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 586var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 595var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 602var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 632var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 640var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 648var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
39await foreach (var item in resourceNotificationService.WatchAsync()) 86await foreach (var item in resourceNotificationService.WatchAsync()) 184await foreach (var item in resourceNotificationService.WatchAsync()) 249await foreach (var item in resourceNotificationService.WatchAsync()) 300await foreach (var item in resourceNotificationService.WatchAsync()) 415await foreach (var item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
80await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceNotificationTests.cs (14)
50async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 52var values = new List<ResourceEvent>(); 54await foreach (var item in notificationService.WatchAsync(cancellationToken)) 103async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 105var values = new List<ResourceEvent>(); 107await foreach (var item in notificationService.WatchAsync(cancellation)) 444async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 446var values = new List<ResourceEvent>(); 448await foreach (var item in notificationService.WatchAsync(cancellationToken)) 482var firstEvent = values[0]; 487var secondEvent = values[1]; 503async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 505await foreach (var item in notificationService.WatchAsync(cancellationToken)) 521var value = await enumerableTask.DefaultTimeout();
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (2)
384await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 454await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
WithUrlsTests.cs (5)
331await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 367await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 411await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 500await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 621await 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))