6 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
726resourceEvent = new ResourceEvent(state.Resource, resourceId, snapshot); 749resourceEvent = new ResourceEvent(m.Value.Resource, m.Key, m.Value.LastSnapshot); 787yield return new ResourceEvent(state.Value.Resource, resourceId, snapshot); 888OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
794await eventing.PublishAsync<ResourceStoppedEvent>(new(portResource, e.Services, new(portResource, portResource.Name, stoppedSnapshot!)), ct).ConfigureAwait(false);
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
330var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
306 references to ResourceEvent
Aspire.Hosting (68)
ApplicationModel\BeforeResourceStartedEvent.cs (1)
27/// <see cref="ResourceEvent.ResourceId"/> for that instance.
ApplicationModel\CommandsConfigurationExtensions.cs (2)
223if (resourceNotificationService.TryGetCurrentState(name, out var evt)) 278await foreach (var evt in resourceNotificationService.WatchAsync(buildTimeoutCts.Token).ConfigureAwait(false))
ApplicationModel\ResourceCommandService.cs (4)
215if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent)) 273if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent)) 472if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent)) 502if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent))
ApplicationModel\ResourceNotificationService.cs (23)
33private Action<ResourceEvent>? OnResourceUpdated { get; set; } 131var resourceEvent = await WaitForResourceCoreAsync( 204public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 237public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 256var resourceEvent = await WaitForResourceCoreAsync( 327var resourceEvent = await WaitForResourceCoreAsync( 373Func<ILogger, string, string, ResourceEvent, Task> postRunningAction, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null) 391var resourceEvent = await WaitForResourceCoreAsync( 643/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 648public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 651var resourceEvent = await WaitForResourceCoreAsync( 661private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, string cancellationMessage, CancellationToken cancellationToken = default, string waitCondition = "predicate") 672await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 717/// <param name="resourceEvent">When this method returns, contains the <see cref="ResourceEvent"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param> 719public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out ResourceEvent? resourceEvent) 761public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 763var channel = Channel.CreateUnbounded<ResourceEvent>(); 765void WriteToChannel(ResourceEvent resourceEvent) => 793await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 1290if (TryGetCurrentState(resourceName, out var evt) && evt.Snapshot != null) 1330if (TryGetCurrentState(dependencyName, out var dependencyEvent))
ApplicationModel\ResourceStoppedEvent.cs (2)
18public class ResourceStoppedEvent(IResource resource, IServiceProvider services, ResourceEvent resourceEvent) : IDistributedApplicationResourceEvent 29public ResourceEvent ResourceEvent { get; } = resourceEvent;
Ats\NotificationExports.cs (3)
59var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName).ConfigureAwait(false); 82if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 149internal static ResourceEventDto FromResourceEvent(ResourceEvent resourceEvent)
Backchannel\AppHostRpcTarget.cs (1)
125await foreach (var resourceEvent in AsyncEnumerableUtils.ReadUntilCancelledAsync(resourceEvents, linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (12)
678var resourceEvent = await WaitForResourceEventAsync( 709var resourceEvent = await WaitForResourceEventAsync( 733var resourceEvent = await WaitForResourceEventAsync( 748private static async Task<ResourceEvent> WaitForResourceEventAsync( 751Func<ResourceEvent, bool> predicate, 757await foreach (var resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false)) 776if (notificationService.TryGetCurrentState(requestedResourceName, out var resourceEvent)) 828public bool Matches(ResourceEvent resourceEvent) 996if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 1033await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false)) 1047ResourceEvent resourceEvent, 1742return notificationService.TryGetCurrentState(resourceName, out var resourceEvent) && resourceEvent.Snapshot.IsHidden;
Dashboard\DashboardEventHandlers.cs (1)
910await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
96await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
28await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false))
Diagnostics\ProfilingTelemetry.cs (3)
846public void AddResourceWaitCompleted(ResourceEvent resourceEvent, string waitCondition) => 849public void AddResourceWaitObserved(ResourceEvent resourceEvent, string waitCondition) => 1091private void AddResourceWaitEvent(string eventName, ResourceEvent resourceEvent, string waitCondition)
DistributedApplication.cs (1)
819app.ResourceNotifications.TryGetCurrentState(instanceName, out var resourceEvent);
Health\ResourceHealthCheckService.cs (9)
29await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false)) 84resourceNotificationService.TryGetCurrentState(name, out var evt) 140ResourceEvent? currentEvent = null; 329public ResourceMonitorState(ILogger logger, ResourceEvent initialEvent, CancellationToken serviceStoppingToken) 342public ResourceEvent LatestEvent { get; private set; } 350public void SetLatestEvent(ResourceEvent resourceEvent) 366internal async Task<bool> DelayAsync(ResourceEvent? currentEvent, TimeSpan delay, CancellationToken cancellationToken) 389private static bool ShouldInterrupt(ResourceEvent currentEvent, ResourceEvent previousEvent)
Lifecycle\TerminalHostFailureDiagnosticService.cs (1)
59await foreach (var evt in notifications.WatchAsync(stoppingToken).ConfigureAwait(false))
Orchestrator\ApplicationOrchestrator.cs (2)
584if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var previousResourceEvent)) 605if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var currentResourceEvent))
ResourceLoggerForwarderService.cs (1)
42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure (5)
AzureProvisioningController.cs (5)
2160!notificationService.TryGetCurrentState(environmentResource.Name, out var environmentEvent) || 3138if (!notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)) 3380if (!notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)) 3834return notificationService.TryGetCurrentState(resourceName, out var currentEvent) && 3840if (notificationService.TryGetCurrentState(resourceName, out var currentEvent) &&
Aspire.Hosting.Azure.Tests (68)
AzureBicepProvisionerTests.cs (11)
76await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 750Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 784Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 821Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 936Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 987Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1178Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1293Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1761Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 1798var resourceEvent = notificationService.TryGetCurrentState(resourceName, out var currentState)
AzureEnvironmentResourceExtensionsTests.cs (57)
380Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 384Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 496Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 569Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 708Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 743Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out var postgresEvent)); 1385Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1421Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1498Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1668Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1723Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1826Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1829Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 1908Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 1971Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 1974Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1978Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2062Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2135Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2140Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2197Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2200Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2246Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2249Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2252Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2306Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2309Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2460Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2480Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2539Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var runningStorage2Event)); 2555Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2559Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2726Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2729Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2738Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 3039Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3484Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 3537Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 3935Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4039Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4246Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4332Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4341Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4385Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4388Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4444Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4447Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4450Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 4487Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4490Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4684Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4751Assert.True(notifications.TryGetCurrentState(storage.Name, out var storageEvent)); 4754Assert.True(notifications.TryGetCurrentState(storageRoles.Name, out var storageRolesEvent)); 4822Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4852Assert.True(notifications.TryGetCurrentState(azureEnvironment.Name, out var environmentEvent)); 5158if (notifications.TryGetCurrentState(resourceName, out var resourceEvent) && 5174var actualState = notifications.TryGetCurrentState(resourceName, out var finalEvent)
Aspire.Hosting.Blazor (3)
BlazorGatewayExtensions.cs (1)
424await foreach (var resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
BrowserDebuggerHelper.cs (2)
171var minimumSnapshotVersion = notificationService.TryGetCurrentState(dcpInstanceName, out var currentState) 300await foreach (var evt in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Blazor.Tests (1)
BrowserDebuggerHelperTests.cs (1)
146Assert.True(notificationService.TryGetCurrentState(resource.Name, out var currentState));
Aspire.Hosting.Browsers (1)
BrowserLogsBuilderExtensions.cs (1)
186if (resourceNotifications.TryGetCurrentState(parentResource.Name, out var resourceEvent))
Aspire.Hosting.Browsers.Tests (13)
BrowserLogsBuilderExtensionsTests.cs (12)
962var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1032var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1109var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1171var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1233var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1284var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1345var initialEvent = await app.ResourceNotifications.WaitForResourceAsync( 1361var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1408var firstRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1444var secondRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1476var firstCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1492var allCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync(
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (1)
186if (resourceNotifications.TryGetCurrentState(parentResource.Name, out var resourceEvent))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
41var state = await rns.WaitForResourceAsync(
Aspire.Hosting.DevTunnels.Tests (2)
DevTunnelResourceBuilderExtensionsTests.cs (2)
628var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 665Assert.True(notifications.TryGetCurrentState(port.Name, out var resourceEvent));
Aspire.Hosting.DotnetTool.Tests (2)
DotnetToolFunctionalTests.cs.cs (2)
28Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState)); 50Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState));
Aspire.Hosting.EntityFrameworkCore (1)
EFCoreOperationExecutor.cs (1)
345var resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.Maui.Tests (3)
MauiBuildQueueTests.cs (3)
127await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 161await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 789await foreach (var evt in env.NotificationService.WatchAsync(cts.Token))
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
611var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
588var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Testing.Tests (2)
DashboardUrlTests.cs (1)
105var runningResourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (130)
Codespaces\CodespacesUrlRewriterTests.cs (1)
80var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (18)
209var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 255var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 256var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 277var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 285var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 392var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 544var notStartedResourceEvent = await rns.WaitForResourceAsync( 549var dependentResourceEvent = await rns.WaitForResourceAsync( 573var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 580var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 630ResourceEvent? notStartedResourceEvent = null; 631ResourceEvent? dependentResourceEvent = null; 658var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 665var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1106var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2154var containerEvent = await rns.WaitForResourceAsync( 2159var executableEvent = await rns.WaitForResourceAsync( 2376private static object? GetResourcePropertyValue(ResourceEvent resourceEvent, string propertyName)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
330var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
ExternalServiceTests.cs (3)
340var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 367var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 394var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 46var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 129var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 603var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 649var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (2)
250await foreach (var evt in notifications.WatchAsync(CancellationToken.None)) 261await foreach (var evt in notifications.WatchAsync(CancellationToken.None))
Orchestrator\ApplicationOrchestratorTests.cs (25)
49await foreach (var item in resourceNotificationService.WatchAsync()) 97await foreach (var item in resourceNotificationService.WatchAsync()) 197await foreach (var item in resourceNotificationService.WatchAsync()) 263await foreach (var item in resourceNotificationService.WatchAsync()) 315await foreach (var item in resourceNotificationService.WatchAsync()) 471Assert.True(resourceNotificationService.TryGetCurrentState(resource.Resource.Name, out var currentState)); 518Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out var snapshotEvent)); 546Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out var snapshotEvent)); 570Assert.True(resourceNotificationService.TryGetCurrentState("tool-dcp", out var snapshotEvent)); 602Assert.True(resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out var waitingEvent)); 643Assert.True(resourceNotificationService.TryGetCurrentState(dependency.Resource.Name, out var dependencyEvent)); 753Assert.True(resourceNotificationService.TryGetCurrentState("waiter-def456", out var siblingEvent)); 916Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out var blockerEvent)); 965while (!resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out var waiterEvent) 982Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out var blockerEvent)); 1048var waitingEvent = await resourceNotificationService.WaitForResourceAsync( 1317var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 1318var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null; 1319var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 1364var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 1365var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null; 1366var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 1405await foreach (var item in resourceNotificationService.WatchAsync()) 1462await foreach (var item in resourceNotificationService.WatchAsync()) 1516await foreach (var item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
89await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceNotificationTests.cs (56)
80await foreach (var item in notificationService.WatchAsync(cts.Token)) 89var resourceEvent = await watchTask.DefaultTimeout(); 102async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 104var values = new List<ResourceEvent>(); 106await foreach (var item in notificationService.WatchAsync(cancellationToken)) 159Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 180async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 182var values = new List<ResourceEvent>(); 184await foreach (var item in notificationService.WatchAsync(cancellation)) 371var waitingEvent = await notificationService.WaitForResourceAsync( 384var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 399Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 419var waitingEvent = await notificationService.WaitForResourceAsync( 437var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 457Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 475var waitingEvent = await notificationService.WaitForResourceAsync( 489var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 505Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 529var waitingEvent = await notificationService.WaitForResourceAsync( 576Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 614Assert.True(notificationService.TryGetCurrentState("resource-def456", out var notStartedEvent)); 654Assert.True(notificationService.TryGetCurrentState("resource-abc123", out var notStartedEvent)); 680var waitingEvent = await notificationService.WaitForResourceAsync( 719var waitingEvent = await notificationService.WaitForResourceAsync( 751var waitingEvent = await notificationService.WaitForResourceAsync( 764var partialWaitingEvent = await notificationService.WaitForResourceAsync( 779Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 795Assert.True(notificationService.TryGetCurrentState(resource.Name, out var waitingEvent)); 803Assert.True(notificationService.TryGetCurrentState(resource.Name, out var runningEvent)); 1038async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 1040var values = new List<ResourceEvent>(); 1042await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1076var firstEvent = values[0]; 1081var secondEvent = values[1]; 1098async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 1100await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1116var value = await enumerableTask.DefaultTimeout(); 1134async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 1136await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1152var value = await enumerableTask.DefaultTimeout(); 1294var resourceEvent = await waitTask.DefaultTimeout(); 1363var resourceEvent = await waitTask.DefaultTimeout(); 1415Assert.True(notificationService.TryGetCurrentState(resourceBuilder.Resource.Name, out var resourceEvent)); 1460Assert.True(notificationService.TryGetCurrentState("myResource", out var initial)); 1464Assert.True(notificationService.TryGetCurrentState("myResource", out var unchanged)); 1469Assert.True(notificationService.TryGetCurrentState("myResource", out var changed)); 1525Assert.True(notificationService.TryGetCurrentState("myResource", out var initial)); 1529Assert.True(notificationService.TryGetCurrentState("myResource", out var unchanged)); 1542Assert.True(notificationService.TryGetCurrentState("myResource", out var changed)); 1554Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1561Assert.True(notificationService.TryGetCurrentState(resource.Name, out var unchanged)); 1577Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1580Assert.True(notificationService.TryGetCurrentState(resource.Name, out var changed)); 1606Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1612Assert.True(notificationService.TryGetCurrentState(resource.Name, out var changed)); 1619private static string[] GetWaitingForDependencies(ResourceEvent resourceEvent)
WithHttpCommandTests.cs (4)
955var startingEvent = await app.ResourceNotifications.WaitForResourceAsync( 968var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1011var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1026var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync(
WithUrlsTests.cs (7)
387var resourceEvent = await rns.WaitForResourceAsync( 412var resourceEvent = await rns.WaitForResourceAsync( 445var resourceEvent = await rns.WaitForResourceAsync( 478await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 594await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 671var resourceEvent = await rns.WaitForResourceAsync( 972var resourceEvent = await rns.WaitForResourceAsync(
Aspire.Hosting.TestUtilities (3)
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Utils\PersistentContainerTestHelpers.cs (2)
129var resourceEvent = await resourceNotificationService.WaitForResourceAsync(resourceName, evt => 157private static object? GetPropertyValue(ResourceEvent resourceEvent, string propertyName) =>
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))