8 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
765resourceEvent = new ResourceEvent(state.Resource, resourceId, snapshot); 788resourceEvent = new ResourceEvent(m.Value.Resource, m.Key, m.Value.LastSnapshot); 826yield return new ResourceEvent(state.Value.Resource, resourceId, snapshot); 925OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
842.PublishAsync(new ResourceStoppedEvent(portResource, services, new(portResource, portResource.Name, stoppedSnapshot!)),
Aspire.Hosting.MongoDB.Tests (1)
ReplicaSet\AddMongoDBReplicaSetTests.cs (1)
347var stoppedResourceEvent = new ResourceEvent(mongo1.Resource, mongo1.Resource.Name, stoppedSnapshot);
Aspire.Hosting.Tests (2)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
330var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
ResourceCommandAnnotationTests.cs (1)
225var resourceEvent = new ResourceEvent(resource, "project-rebuilder", new CustomResourceSnapshot
350 references to ResourceEvent
Aspire.Hosting (68)
ApplicationModel\BeforeResourceStartedEvent.cs (1)
27/// <see cref="ResourceEvent.ResourceId"/> for that instance.
ApplicationModel\CommandsConfigurationExtensions.cs (3)
216if (resourceNotificationService.TryGetCurrentState(name, out var evt)) 273var terminalEvent = await resourceNotificationService.WaitForResourceAsync(rebuilderResource.Name, 388internal static bool IsRebuildComplete(ResourceEvent resourceEvent, string rebuilderInstanceName)
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; } 137var resourceEvent = await waitTask.ConfigureAwait(false); 209public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 242public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 273var resourceEvent = await healthyTask.ConfigureAwait(false); 356var resourceEvent = await WaitForResourceCoreAsync( 402Func<ILogger, string, string, ResourceEvent, Task> postRunningAction, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null) 420var resourceEvent = await WaitForResourceCoreAsync( 673/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 678public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 691var resourceEvent = await waitTask.ConfigureAwait(false); 700private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, string cancellationMessage, CancellationToken cancellationToken = default, string waitCondition = "predicate") 711await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 756/// <param name="resourceEvent">When this method returns, contains the <see cref="ResourceEvent"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param> 758public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out ResourceEvent? resourceEvent) 800public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 802var channel = Channel.CreateUnbounded<ResourceEvent>(); 804void WriteToChannel(ResourceEvent resourceEvent) => 830await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 1327if (TryGetCurrentState(resourceName, out var evt) && evt.Snapshot != null) 1367if (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)
700var resourceEvent = await WaitForResourceEventAsync( 731var resourceEvent = await WaitForResourceEventAsync( 755var resourceEvent = await WaitForResourceEventAsync( 770private static async Task<ResourceEvent> WaitForResourceEventAsync( 773Func<ResourceEvent, bool> predicate, 779await foreach (var resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false)) 798if (notificationService.TryGetCurrentState(requestedResourceName, out var resourceEvent)) 850public bool Matches(ResourceEvent resourceEvent) 1018if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 1055await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false)) 1069ResourceEvent resourceEvent, 1764return notificationService.TryGetCurrentState(resourceName, out var resourceEvent) && resourceEvent.Snapshot.IsHidden;
Dashboard\DashboardEventHandlers.cs (1)
756await 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)
831app.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 (1)
595if (_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)
2157!notificationService.TryGetCurrentState(environmentResource.Name, out var environmentEvent) || 3135if (!notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)) 3377if (!notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)) 3831return notificationService.TryGetCurrentState(resourceName, out var currentEvent) && 3837if (notificationService.TryGetCurrentState(resourceName, out var currentEvent) &&
Aspire.Hosting.Azure.EntraId.Tests (1)
EntraIdInitializationTests.cs (1)
325Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent));
Aspire.Hosting.Azure.Tests (68)
AzureBicepProvisionerTests.cs (11)
73await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 747Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 781Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 818Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 933Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 984Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1175Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1290Assert.True(notifications.TryGetCurrentState(resource.Name, out var resourceEvent)); 1758Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 1795var resourceEvent = notificationService.TryGetCurrentState(resourceName, out var currentState)
AzureEnvironmentResourceExtensionsTests.cs (57)
377Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 381Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 493Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 566Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 705Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 740Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out var postgresEvent)); 1382Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1418Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1495Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1665Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1720Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1823Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1826Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 1905Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 1968Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 1971Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 1975Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2059Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2132Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2137Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2194Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2197Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2243Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2246Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2249Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2303Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2306Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2457Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2477Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2536Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var runningStorage2Event)); 2552Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2556Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 2723Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2726Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2735Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 3036Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 3481Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 3534Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 3932Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4036Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out var keyVaultEvent)); 4243Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4329Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4338Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4382Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4385Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4441Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4444Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4447Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out var storage2Event)); 4484Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4487Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var resourceEvent)); 4681Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 4748Assert.True(notifications.TryGetCurrentState(storage.Name, out var storageEvent)); 4751Assert.True(notifications.TryGetCurrentState(storageRoles.Name, out var storageRolesEvent)); 4819Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 4849Assert.True(notifications.TryGetCurrentState(azureEnvironment.Name, out var environmentEvent)); 5167if (notifications.TryGetCurrentState(resourceName, out var resourceEvent) && 5183var actualState = notifications.TryGetCurrentState(resourceName, out var finalEvent)
Aspire.Hosting.Blazor (3)
BlazorGatewayExtensions.cs (1)
512await 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)
961var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1031var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1108var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1170var failedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1232var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1283var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1344var initialEvent = await app.ResourceNotifications.WaitForResourceAsync( 1360var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync( 1407var firstRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1443var secondRunningEvent = await app.ResourceNotifications.WaitForResourceAsync( 1475var firstCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync( 1491var 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 (6)
DevTunnelMonitor.cs (3)
434await foreach (var update in _notifications.WatchAsync(run.Cancellation.Token).ConfigureAwait(false)) 479if (_notifications.TryGetCurrentState(_resource.Name, out var current) 701&& (!_notifications.TryGetCurrentState(_resource.Name, out var current)
DevTunnelResourceBuilderExtensions.cs (3)
740var wasAvailable = notifications.TryGetCurrentState(portResource.Name, out var previous) 802var previousPolicy = notifications.TryGetCurrentState(portResource.Name, out var current) 823if (notifications.TryGetCurrentState(portResource.Name, out var current)
Aspire.Hosting.DevTunnels.Tests (4)
DevTunnelResourceBuilderExtensionsTests.cs (3)
779var completed = await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name, 801var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 847Assert.True(notifications.TryGetCurrentState(port.Name, out var resourceEvent));
TestDevTunnelMonitor.cs (1)
93Assert.True(App.ResourceNotifications.TryGetCurrentState(resource.Name, out var current));
Aspire.Hosting.Dotnet (4)
DotnetProjectBuildCoordinator.cs (4)
187var buildEvent = await notificationService.WaitForResourceAsync( 304notifications.TryGetCurrentState(rebuilder.Name, out var rebuildEvent) && 926out var resourceEvent) 1006out var resourceEvent)
Aspire.Hosting.Dotnet.Tests (8)
DotnetProjectBuildCoordinatorTests.cs (8)
2888var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2937var firstBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 2941var secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3172Assert.True(app.ResourceNotifications.TryGetCurrentState("persistent-project", out var projectEvent)); 3580ResourceEvent buildEvent; 3646var workerStartingEvent = await workerStartingTask; 3681var buildEvent = await app.ResourceNotifications.WaitForResourceAsync( 3691var workerEvent = await app.ResourceNotifications.WaitForResourceAsync(
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)
360var resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.EntityFrameworkCore.Tests (1)
EFBuildReadinessTests.cs (1)
48Assert.True(app.ResourceNotifications.TryGetCurrentState(migrations.Resource.Name, out var state));
Aspire.Hosting.Maui (3)
MauiOtlpExtensions.cs (3)
410if (notificationService.TryGetCurrentState(resourceName, out var currentState) && 424ResourceEvent resourceEvent; 445ResourceEvent resourceEvent)
Aspire.Hosting.Maui.Tests (3)
MauiBuildQueueTests.cs (3)
129await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 163await foreach (var evt in env.NotificationService.WatchAsync(cts.Token)) 1163await foreach (var evt in env.NotificationService.WatchAsync(cts.Token))
Aspire.Hosting.MongoDB (2)
MongoDBSingleMemberReplicaSet.cs (1)
40await foreach (var update in evt.Notifications.WatchAsync(stopping.Token).ConfigureAwait(false))
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.MongoDB.Tests (4)
ReplicaSet\AddMongoDBReplicaSetTests.cs (2)
347var stoppedResourceEvent = new ResourceEvent(mongo1.Resource, mongo1.Resource.Name, stoppedSnapshot); 368Assert.True(notifications.TryGetCurrentState(replicaSet.Resource.Name, out var resourceEvent));
SingleMemberReplicaSetFunctionalTests.cs (2)
166var completed = await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name, 196var running = await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, ready.Token);
Aspire.Hosting.MySql (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
611var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
588var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Redis (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.Redis.Tests (4)
RedisFunctionalTests.cs (4)
120var commanderEvent = await app.ResourceNotifications.WaitForResourceAsync( 128var redisEvent = await app.ResourceNotifications.WaitForResourceAsync( 166var redisEvent = await app.ResourceNotifications.WaitForResourceAsync( 178var commanderEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.SqlServer (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
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 (134)
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); 396var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 548var notStartedResourceEvent = await rns.WaitForResourceAsync( 553var dependentResourceEvent = await rns.WaitForResourceAsync( 577var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 584var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 634ResourceEvent? notStartedResourceEvent = null; 635ResourceEvent? dependentResourceEvent = null; 662var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 669var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1110var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2165var containerEvent = await rns.WaitForResourceAsync( 2170var executableEvent = await rns.WaitForResourceAsync( 2387private 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)
94await foreach (var item in resourceNotificationService.WatchAsync()) 142await foreach (var item in resourceNotificationService.WatchAsync()) 242await foreach (var item in resourceNotificationService.WatchAsync()) 308await foreach (var item in resourceNotificationService.WatchAsync()) 360await foreach (var item in resourceNotificationService.WatchAsync()) 516Assert.True(resourceNotificationService.TryGetCurrentState(resource.Resource.Name, out var currentState)); 563Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out var snapshotEvent)); 591Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out var snapshotEvent)); 615Assert.True(resourceNotificationService.TryGetCurrentState("tool-dcp", out var snapshotEvent)); 647Assert.True(resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out var waitingEvent)); 688Assert.True(resourceNotificationService.TryGetCurrentState(dependency.Resource.Name, out var dependencyEvent)); 798Assert.True(resourceNotificationService.TryGetCurrentState("waiter-def456", out var siblingEvent)); 961Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out var blockerEvent)); 1010while (!resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out var waiterEvent) 1027Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out var blockerEvent)); 1093var waitingEvent = await resourceNotificationService.WaitForResourceAsync( 1363var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 1364var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null; 1365var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 1411var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 1412var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null; 1413var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 1452await foreach (var item in resourceNotificationService.WatchAsync()) 1509await foreach (var item in resourceNotificationService.WatchAsync()) 1563await foreach (var item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
88await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceCommandAnnotationTests.cs (1)
225var resourceEvent = new ResourceEvent(resource, "project-rebuilder", new CustomResourceSnapshot
ResourceNotificationTests.cs (58)
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)) 417var waitingEvent = await notificationService.WaitForResourceAsync( 430var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 445Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 465var waitingEvent = await notificationService.WaitForResourceAsync( 483var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 503Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 521var waitingEvent = await notificationService.WaitForResourceAsync( 535var updatedWaitingEvent = await notificationService.WaitForResourceAsync( 551Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 575var waitingEvent = await notificationService.WaitForResourceAsync( 622Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 660Assert.True(notificationService.TryGetCurrentState("resource-def456", out var notStartedEvent)); 700Assert.True(notificationService.TryGetCurrentState("resource-abc123", out var notStartedEvent)); 726var waitingEvent = await notificationService.WaitForResourceAsync( 765var waitingEvent = await notificationService.WaitForResourceAsync( 797var waitingEvent = await notificationService.WaitForResourceAsync( 810var partialWaitingEvent = await notificationService.WaitForResourceAsync( 825Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 841Assert.True(notificationService.TryGetCurrentState(resource.Name, out var waitingEvent)); 849Assert.True(notificationService.TryGetCurrentState(resource.Name, out var runningEvent)); 1084async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 1086var values = new List<ResourceEvent>(); 1088await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1122var firstEvent = values[0]; 1127var secondEvent = values[1]; 1144async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 1146await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1162var value = await enumerableTask.DefaultTimeout(); 1180async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 1182await foreach (var item in notificationService.WatchAsync(cancellationToken)) 1198var value = await enumerableTask.DefaultTimeout(); 1340var resourceEvent = await waitTask.DefaultTimeout(); 1409var resourceEvent = await waitTask.DefaultTimeout(); 1437var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resource.Name, waitBehavior).DefaultTimeout(); 1564await foreach (var resourceEvent in notificationService.WatchAsync()) 1706Assert.True(notificationService.TryGetCurrentState(resourceBuilder.Resource.Name, out var resourceEvent)); 1751Assert.True(notificationService.TryGetCurrentState("myResource", out var initial)); 1755Assert.True(notificationService.TryGetCurrentState("myResource", out var unchanged)); 1760Assert.True(notificationService.TryGetCurrentState("myResource", out var changed)); 1816Assert.True(notificationService.TryGetCurrentState("myResource", out var initial)); 1820Assert.True(notificationService.TryGetCurrentState("myResource", out var unchanged)); 1833Assert.True(notificationService.TryGetCurrentState("myResource", out var changed)); 1845Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1852Assert.True(notificationService.TryGetCurrentState(resource.Name, out var unchanged)); 1868Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1871Assert.True(notificationService.TryGetCurrentState(resource.Name, out var changed)); 1897Assert.True(notificationService.TryGetCurrentState(resource.Name, out var initial)); 1903Assert.True(notificationService.TryGetCurrentState(resource.Name, out var changed)); 1910private 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 (8)
407var resourceEvent = await rns.WaitForResourceAsync( 432var resourceEvent = await rns.WaitForResourceAsync( 465var resourceEvent = await rns.WaitForResourceAsync( 498await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 614await foreach (var notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration)) 691var resourceEvent = await rns.WaitForResourceAsync( 1080var resourceEvent = await rns.WaitForResourceAsync( 1132var 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.Hosting.Valkey (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))