161 references to TryGetCurrentState
Aspire.Hosting (15)
ApplicationModel\CommandsConfigurationExtensions.cs (1)
216if (resourceNotificationService.TryGetCurrentState(name, out var evt))
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 (3)
244if (waitBehavior == WaitBehavior.StopOnResourceUnavailable && !TryGetCurrentState(resourceName, out _)) 1327if (TryGetCurrentState(resourceName, out var evt) && evt.Snapshot != null) 1367if (TryGetCurrentState(dependencyName, out var dependencyEvent))
Ats\NotificationExports.cs (1)
82if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (3)
798if (notificationService.TryGetCurrentState(requestedResourceName, out var resourceEvent)) 1018if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 1764return notificationService.TryGetCurrentState(resourceName, out var resourceEvent) && resourceEvent.Snapshot.IsHidden;
DistributedApplication.cs (1)
831app.ResourceNotifications.TryGetCurrentState(instanceName, out var resourceEvent);
Health\ResourceHealthCheckService.cs (1)
84resourceNotificationService.TryGetCurrentState(name, out var evt)
Orchestrator\ApplicationOrchestrator.cs (1)
595if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var currentResourceEvent))
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 (74)
AzureBicepProvisionerTests.cs (9)
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 (65)
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)); 2257Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out environmentEvent)); 2260Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2303Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out var environmentEvent)); 2306Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2315Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out environmentEvent)); 2318Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2457Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out var storageEvent)); 2474Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 2477Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out var blobsEvent)); 2486Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out storageEvent)); 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)); 2561Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out 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)); 4825Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out 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 (1)
BrowserDebuggerHelper.cs (1)
171var minimumSnapshotVersion = notificationService.TryGetCurrentState(dcpInstanceName, out var currentState)
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 (1)
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (1)
186if (resourceNotifications.TryGetCurrentState(parentResource.Name, out var resourceEvent))
Aspire.Hosting.DevTunnels (5)
DevTunnelMonitor.cs (2)
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 (2)
DevTunnelResourceBuilderExtensionsTests.cs (1)
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 (3)
DotnetProjectBuildCoordinator.cs (3)
304notifications.TryGetCurrentState(rebuilder.Name, out var rebuildEvent) && 924var initialSnapshot = _notificationService.TryGetCurrentState( 1004var initialSnapshot = _notificationService.TryGetCurrentState(
Aspire.Hosting.Dotnet.Tests (1)
DotnetProjectBuildCoordinatorTests.cs (1)
3172Assert.True(app.ResourceNotifications.TryGetCurrentState("persistent-project", out var projectEvent));
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.Tests (1)
EFBuildReadinessTests.cs (1)
48Assert.True(app.ResourceNotifications.TryGetCurrentState(migrations.Resource.Name, out var state));
Aspire.Hosting.Maui (1)
MauiOtlpExtensions.cs (1)
410if (notificationService.TryGetCurrentState(resourceName, out var currentState) &&
Aspire.Hosting.MongoDB (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.MongoDB.Tests (1)
ReplicaSet\AddMongoDBReplicaSetTests.cs (1)
368Assert.True(notifications.TryGetCurrentState(replicaSet.Resource.Name, out var resourceEvent));
Aspire.Hosting.MySql (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.PostgreSQL (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.Redis (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.SqlServer (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||
Aspire.Hosting.Tests (40)
Orchestrator\ApplicationOrchestratorTests.cs (16)
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)); 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;
ResourceNotificationTests.cs (24)
159Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 445Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 503Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 551Assert.True(notificationService.TryGetCurrentState(resource.Name, out var completedWaitingEvent)); 622Assert.True(notificationService.TryGetCurrentState(resource.Name, out var resourceEvent)); 660Assert.True(notificationService.TryGetCurrentState("resource-def456", out var notStartedEvent)); 670Assert.True(notificationService.TryGetCurrentState("resource-def456", out notStartedEvent)); 700Assert.True(notificationService.TryGetCurrentState("resource-abc123", out var notStartedEvent)); 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)); 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));
Aspire.Hosting.Valkey (1)
src\Shared\ContainerReplCommand.cs (1)
28if (!notifications.TryGetCurrentState(context.ResourceName, out var resourceEvent) ||