8 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
786
resourceEvent = new
ResourceEvent
(state.Resource, resourceId, snapshot);
809
resourceEvent = new
ResourceEvent
(m.Value.Resource, m.Key, m.Value.LastSnapshot);
847
yield return new
ResourceEvent
(state.Value.Resource, resourceId, snapshot);
957
OnResourceUpdated?.Invoke(new
ResourceEvent
(resource, resourceId, newState));
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
849
.PublishAsync(new ResourceStoppedEvent(portResource, services,
new
(portResource, portResource.Name, stoppedSnapshot!)),
Aspire.Hosting.MongoDB.Tests (1)
ReplicaSet\AddMongoDBReplicaSetTests.cs (1)
347
var stoppedResourceEvent = new
ResourceEvent
(mongo1.Resource, mongo1.Resource.Name, stoppedSnapshot);
Aspire.Hosting.Tests (2)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
362
var testResourceEvent = new
ResourceEvent
(resource.Resource, "test-resource", testSnapshot);
ResourceCommandAnnotationTests.cs (1)
225
var resourceEvent = new
ResourceEvent
(resource, "project-rebuilder", new CustomResourceSnapshot
368 references to ResourceEvent
Aspire.Hosting (68)
ApplicationModel\BeforeResourceStartedEvent.cs (1)
27
/// <see cref="
ResourceEvent
.ResourceId"/> for that instance.
ApplicationModel\CommandsConfigurationExtensions.cs (3)
216
if (resourceNotificationService.TryGetCurrentState(name, out
var
evt))
282
var
terminalEvent = await resourceNotificationService.WaitForResourceAsync(rebuilderResource.Name,
433
internal static bool IsRebuildComplete(
ResourceEvent
resourceEvent, string rebuilderInstanceName)
ApplicationModel\ResourceCommandService.cs (4)
215
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
273
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
472
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
502
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
ApplicationModel\ResourceNotificationService.cs (23)
33
private Action<
ResourceEvent
>? OnResourceUpdated { get; set; }
137
var
resourceEvent = await waitTask.ConfigureAwait(false);
209
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default)
242
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default)
273
var
resourceEvent = await healthyTask.ConfigureAwait(false);
356
var
resourceEvent = await WaitForResourceCoreAsync(
402
Func<ILogger, string, string,
ResourceEvent
, Task> postRunningAction, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null)
420
var
resourceEvent = await WaitForResourceCoreAsync(
694
/// <param name="predicate">A predicate which is evaluated for each <see cref="
ResourceEvent
"/> for the selected resource.</param>
699
public async Task<
ResourceEvent
> WaitForResourceAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
712
var
resourceEvent = await waitTask.ConfigureAwait(false);
721
private async Task<
ResourceEvent
> WaitForResourceCoreAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, string cancellationMessage, CancellationToken cancellationToken = default, string waitCondition = "predicate")
732
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
777
/// <param name="resourceEvent">When this method returns, contains the <see cref="
ResourceEvent
"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param>
779
public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out
ResourceEvent
? resourceEvent)
821
public async IAsyncEnumerable<
ResourceEvent
> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
823
var channel = Channel.CreateUnbounded<
ResourceEvent
>();
825
void WriteToChannel(
ResourceEvent
resourceEvent) =>
851
await foreach (
var
item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
1359
if (TryGetCurrentState(resourceName, out
var
evt) && evt.Snapshot != null)
1399
if (TryGetCurrentState(dependencyName, out
var
dependencyEvent))
ApplicationModel\ResourceStoppedEvent.cs (2)
18
public class ResourceStoppedEvent(IResource resource, IServiceProvider services,
ResourceEvent
resourceEvent) : IDistributedApplicationResourceEvent
29
public
ResourceEvent
ResourceEvent { get; } = resourceEvent;
Ats\NotificationExports.cs (3)
59
var
resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName).ConfigureAwait(false);
82
if (notificationService.TryGetCurrentState(resourceName, out
var
resourceEvent))
149
internal static ResourceEventDto FromResourceEvent(
ResourceEvent
resourceEvent)
Backchannel\AppHostRpcTarget.cs (1)
127
await foreach (
var
resourceEvent in AsyncEnumerableUtils.ReadUntilCancelledAsync(resourceEvents, linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (12)
700
var
resourceEvent = await WaitForResourceEventAsync(
731
var
resourceEvent = await WaitForResourceEventAsync(
755
var
resourceEvent = await WaitForResourceEventAsync(
770
private static async Task<
ResourceEvent
> WaitForResourceEventAsync(
773
Func<
ResourceEvent
, bool> predicate,
779
await foreach (
var
resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
798
if (notificationService.TryGetCurrentState(requestedResourceName, out
var
resourceEvent))
850
public bool Matches(
ResourceEvent
resourceEvent)
1018
if (notificationService.TryGetCurrentState(resourceName, out
var
resourceEvent))
1055
await foreach (
var
resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))
1069
ResourceEvent
resourceEvent,
1766
return notificationService.TryGetCurrentState(resourceName, out
var
resourceEvent) && resourceEvent.Snapshot.IsHidden;
Dashboard\DashboardEventHandlers.cs (1)
781
await foreach (
var
notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
97
await foreach (
var
@event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
28
await foreach (
var
resourceEvent in resourceEvents.ConfigureAwait(false))
Diagnostics\ProfilingTelemetry.cs (3)
846
public void AddResourceWaitCompleted(
ResourceEvent
resourceEvent, string waitCondition) =>
849
public void AddResourceWaitObserved(
ResourceEvent
resourceEvent, string waitCondition) =>
1091
private void AddResourceWaitEvent(string eventName,
ResourceEvent
resourceEvent, string waitCondition)
DistributedApplication.cs (1)
849
app.ResourceNotifications.TryGetCurrentState(instanceName, out
var
resourceEvent);
Health\ResourceHealthCheckService.cs (9)
29
await foreach (
var
resourceEvent in resourceEvents.ConfigureAwait(false))
84
resourceNotificationService.TryGetCurrentState(name, out
var
evt)
140
ResourceEvent
? currentEvent = null;
337
public ResourceMonitorState(ILogger logger,
ResourceEvent
initialEvent, CancellationToken serviceStoppingToken)
350
public
ResourceEvent
LatestEvent { get; private set; }
358
public void SetLatestEvent(
ResourceEvent
resourceEvent)
374
internal async Task<bool> DelayAsync(
ResourceEvent
? currentEvent, TimeSpan delay, CancellationToken cancellationToken)
397
private static bool ShouldInterrupt(
ResourceEvent
currentEvent,
ResourceEvent
previousEvent)
Lifecycle\TerminalHostFailureDiagnosticService.cs (1)
59
await foreach (
var
evt in notifications.WatchAsync(stoppingToken).ConfigureAwait(false))
Orchestrator\ApplicationOrchestrator.cs (1)
662
if (_notificationService.TryGetCurrentState(context.DcpResourceName, out
var
currentResourceEvent))
ResourceLoggerForwarderService.cs (1)
42
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure (5)
AzureProvisioningController.cs (5)
2256
!notificationService.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent) ||
3264
if (!notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent))
3506
if (!notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent))
3965
return notificationService.TryGetCurrentState(resourceName, out
var
currentEvent) &&
3971
if (notificationService.TryGetCurrentState(resourceName, out
var
currentEvent) &&
Aspire.Hosting.Azure.EntraId (1)
EntraIdResourceExtensions.cs (1)
110
await foreach (
var
update in evt.Notifications.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.EntraId.Tests (5)
EntraIdInitializationTests.cs (5)
256
Assert.True(notifications.TryGetCurrentState(entra.Resource.Name, out
var
resourceEvent));
290
var
ready = await notifications.WaitForResourceAsync(entra.Resource.Name,
336
var
ready = await notifications.WaitForResourceAsync(entra.Resource.Name,
503
var
update = await notifications.WaitForResourceAsync(resource.Name,
517
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
Aspire.Hosting.Azure.Tests (69)
AzureBicepProvisionerTests.cs (10)
817
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
851
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
888
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1003
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1054
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1245
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1360
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1828
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
1865
var
resourceEvent = notificationService.TryGetCurrentState(resourceName, out
var
currentState)
AzureEnvironmentResourceExtensionsTests.cs (59)
120
Assert.True(notifications.TryGetCurrentState(directory.Resource.Name, out
var
directorySnapshot));
676
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
680
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
792
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
817
Assert.True(notifications.TryGetCurrentState(resource.Name, out
var
resourceEvent), $"No state was published for '{resource.Name}'.");
890
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
1051
Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out
var
keyVaultEvent));
1086
Assert.True(notifications.TryGetCurrentState(postgres.Resource.Name, out
var
postgresEvent));
1728
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
1764
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
1841
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2011
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2066
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2169
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2172
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
2251
Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out
var
keyVaultEvent));
2314
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
2317
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2321
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
2405
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2478
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2483
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
2540
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2543
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
2589
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
2592
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2595
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
2649
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
2652
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2803
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2823
Assert.True(notifications.TryGetCurrentState(blobs.Resource.Name, out
var
blobsEvent));
2882
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
runningStorage2Event));
2898
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
2902
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
3069
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
3072
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
3081
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
3382
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
3827
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
3880
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
4278
Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out
var
keyVaultEvent));
4382
Assert.True(notifications.TryGetCurrentState(keyVault.Resource.Name, out
var
keyVaultEvent));
4589
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
4675
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
4684
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
resourceEvent));
4728
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
4731
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
resourceEvent));
4787
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
4790
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
4793
Assert.True(notifications.TryGetCurrentState(storage2.Resource.Name, out
var
storage2Event));
4830
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
4833
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
resourceEvent));
5027
Assert.True(notifications.TryGetCurrentState(environmentResource.Name, out
var
environmentEvent));
5094
Assert.True(notifications.TryGetCurrentState(storage.Name, out
var
storageEvent));
5097
Assert.True(notifications.TryGetCurrentState(storageRoles.Name, out
var
storageRolesEvent));
5165
Assert.True(notifications.TryGetCurrentState(storage.Resource.Name, out
var
storageEvent));
5195
Assert.True(notifications.TryGetCurrentState(azureEnvironment.Name, out
var
environmentEvent));
5513
if (notifications.TryGetCurrentState(resourceName, out
var
resourceEvent) &&
5529
var actualState = notifications.TryGetCurrentState(resourceName, out
var
finalEvent)
Aspire.Hosting.Blazor (3)
BlazorGatewayExtensions.cs (1)
515
await foreach (
var
resourceEvent in notificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
BrowserDebuggerHelper.cs (2)
171
var minimumSnapshotVersion = notificationService.TryGetCurrentState(dcpInstanceName, out
var
currentState)
300
await foreach (
var
evt in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Blazor.Tests (1)
BrowserDebuggerHelperTests.cs (1)
146
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
currentState));
Aspire.Hosting.Browsers (1)
BrowserLogsBuilderExtensions.cs (1)
186
if (resourceNotifications.TryGetCurrentState(parentResource.Name, out
var
resourceEvent))
Aspire.Hosting.Browsers.Tests (13)
BrowserLogsBuilderExtensionsTests.cs (12)
961
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1031
var
failedEvent = await app.ResourceNotifications.WaitForResourceAsync(
1108
var
failedEvent = await app.ResourceNotifications.WaitForResourceAsync(
1170
var
failedEvent = await app.ResourceNotifications.WaitForResourceAsync(
1232
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1283
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1344
var
initialEvent = await app.ResourceNotifications.WaitForResourceAsync(
1360
var
enabledEvent = await app.ResourceNotifications.WaitForResourceAsync(
1407
var
firstRunningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1443
var
secondRunningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1475
var
firstCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync(
1491
var
allCompletedEvent = await app.ResourceNotifications.WaitForResourceAsync(
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (1)
186
if (resourceNotifications.TryGetCurrentState(parentResource.Name, out
var
resourceEvent))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
41
var
state = await rns.WaitForResourceAsync(
Aspire.Hosting.DevTunnels (6)
DevTunnelMonitor.cs (3)
434
await foreach (
var
update in _notifications.WatchAsync(run.Cancellation.Token).ConfigureAwait(false))
479
if (_notifications.TryGetCurrentState(_resource.Name, out
var
current)
701
&& (!_notifications.TryGetCurrentState(_resource.Name, out
var
current)
DevTunnelResourceBuilderExtensions.cs (3)
747
var wasAvailable = notifications.TryGetCurrentState(portResource.Name, out
var
previous)
809
var previousPolicy = notifications.TryGetCurrentState(portResource.Name, out
var
current)
830
if (notifications.TryGetCurrentState(portResource.Name, out
var
current)
Aspire.Hosting.DevTunnels.Tests (4)
DevTunnelResourceBuilderExtensionsTests.cs (3)
822
var
completed = await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name,
844
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
892
Assert.True(notifications.TryGetCurrentState(port.Name, out
var
resourceEvent));
TestDevTunnelMonitor.cs (1)
94
Assert.True(App.ResourceNotifications.TryGetCurrentState(resource.Name, out
var
current));
Aspire.Hosting.Dotnet (5)
DotnetProjectBuildCoordinator.cs (5)
211
var
buildEvent = await notificationService.WaitForResourceAsync(
266
.TryGetCurrentState(@event.ResourceEvent.ResourceId, out
var
current) &&
518
notifications.TryGetCurrentState(rebuilder.Name, out
var
rebuildEvent) &&
1224
out
var
resourceEvent)
1304
out
var
resourceEvent)
Aspire.Hosting.Dotnet.Tests (13)
DotnetProjectBuildCoordinatorTests.cs (13)
1848
Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out
var
stoppedEvent));
1898
Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out
var
firstStoppedEvent));
1922
Assert.True(app.ResourceNotifications.TryGetCurrentState(buildResource.Name, out
var
secondStoppedEvent));
2239
var
buildEvent = await app.ResourceNotifications.WaitForResourceAsync(
3810
foreach (
var
completedResource in completedResources)
3909
var
secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync(
3958
var
firstBuildEvent = await app.ResourceNotifications.WaitForResourceAsync(
3962
var
secondBuildEvent = await app.ResourceNotifications.WaitForResourceAsync(
4251
Assert.True(app.ResourceNotifications.TryGetCurrentState("persistent-project", out
var
projectEvent));
4664
ResourceEvent
buildEvent;
4730
var
workerStartingEvent = await workerStartingTask;
4765
var
buildEvent = await app.ResourceNotifications.WaitForResourceAsync(
4775
var
workerEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.DotnetTool.Tests (2)
DotnetToolFunctionalTests.cs.cs (2)
28
Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out
var
resourceState));
50
Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out
var
resourceState));
Aspire.Hosting.EntityFrameworkCore (1)
EFCoreOperationExecutor.cs (1)
360
var
resourceEvent = await notificationService.WaitForResourceAsync(
Aspire.Hosting.EntityFrameworkCore.Tests (1)
EFBuildReadinessTests.cs (1)
51
Assert.True(app.ResourceNotifications.TryGetCurrentState(migrations.Resource.Name, out
var
state));
Aspire.Hosting.Maui (3)
MauiOtlpExtensions.cs (3)
410
if (notificationService.TryGetCurrentState(resourceName, out
var
currentState) &&
424
ResourceEvent
resourceEvent;
445
ResourceEvent
resourceEvent)
Aspire.Hosting.MongoDB (2)
MongoDBSingleMemberReplicaSet.cs (1)
40
await foreach (
var
update in evt.Notifications.WatchAsync(stopping.Token).ConfigureAwait(false))
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Hosting.MongoDB.Tests (4)
ReplicaSet\AddMongoDBReplicaSetTests.cs (2)
347
var
stoppedResourceEvent = new ResourceEvent(mongo1.Resource, mongo1.Resource.Name, stoppedSnapshot);
368
Assert.True(notifications.TryGetCurrentState(replicaSet.Resource.Name, out
var
resourceEvent));
SingleMemberReplicaSetFunctionalTests.cs (2)
166
var
completed = await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name,
196
var
running = await app.ResourceNotifications.WaitForResourceHealthyAsync(mongo1.Resource.Name, ready.Token);
Aspire.Hosting.MySql (1)
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
611
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL (1)
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
588
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Redis (1)
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Hosting.Redis.Tests (4)
RedisFunctionalTests.cs (4)
120
var
commanderEvent = await app.ResourceNotifications.WaitForResourceAsync(
128
var
redisEvent = await app.ResourceNotifications.WaitForResourceAsync(
166
var
redisEvent = await app.ResourceNotifications.WaitForResourceAsync(
178
var
commanderEvent = await app.ResourceNotifications.WaitForResourceAsync(
Aspire.Hosting.SqlServer (1)
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Hosting.Testing.Tests (2)
DashboardUrlTests.cs (1)
105
var
runningResourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (143)
Codespaces\CodespacesUrlRewriterTests.cs (1)
102
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (19)
263
var
resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
309
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
310
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
331
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
339
var
dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
408
var
normalResource = await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, startupToken).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
470
var
notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
622
var
notStartedResourceEvent = await rns.WaitForResourceAsync(
627
var
dependentResourceEvent = await rns.WaitForResourceAsync(
651
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
658
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
708
ResourceEvent
? notStartedResourceEvent = null;
709
ResourceEvent
? dependentResourceEvent = null;
736
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
743
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
1184
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
2243
var
containerEvent = await rns.WaitForResourceAsync(
2248
var
executableEvent = await rns.WaitForResourceAsync(
2465
private static object? GetResourcePropertyValue(
ResourceEvent
resourceEvent, string propertyName)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
362
var
testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
ExternalServiceTests.cs (3)
341
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
368
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
395
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
38
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
46
var
healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
78
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
86
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
121
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
129
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource",
587
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
596
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
603
var
healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
633
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
641
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
649
var
unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (2)
250
await foreach (
var
evt in notifications.WatchAsync(CancellationToken.None))
261
await foreach (
var
evt in notifications.WatchAsync(CancellationToken.None))
Orchestrator\ApplicationOrchestratorTests.cs (26)
194
Assert.True(app.ResourceNotifications.TryGetCurrentState(frontend.Resource.Name, out
var
state));
599
await foreach (
var
item in resourceNotificationService.WatchAsync())
647
await foreach (
var
item in resourceNotificationService.WatchAsync())
747
await foreach (
var
item in resourceNotificationService.WatchAsync())
813
await foreach (
var
item in resourceNotificationService.WatchAsync())
865
await foreach (
var
item in resourceNotificationService.WatchAsync())
1021
Assert.True(resourceNotificationService.TryGetCurrentState(resource.Resource.Name, out
var
currentState));
1068
Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out
var
snapshotEvent));
1096
Assert.True(resourceNotificationService.TryGetCurrentState("api-dcp", out
var
snapshotEvent));
1120
Assert.True(resourceNotificationService.TryGetCurrentState("tool-dcp", out
var
snapshotEvent));
1152
Assert.True(resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out
var
waitingEvent));
1193
Assert.True(resourceNotificationService.TryGetCurrentState(dependency.Resource.Name, out
var
dependencyEvent));
1303
Assert.True(resourceNotificationService.TryGetCurrentState("waiter-def456", out
var
siblingEvent));
1466
Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out
var
blockerEvent));
1515
while (!resourceNotificationService.TryGetCurrentState(waiter.Resource.Name, out
var
waiterEvent)
1532
Assert.True(resourceNotificationService.TryGetCurrentState(blocker.Resource.Name, out
var
blockerEvent));
1598
var
waitingEvent = await resourceNotificationService.WaitForResourceAsync(
1869
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out
var
parentEvent) ? parentEvent.Snapshot.State?.Text : null;
1870
var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out
var
childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null;
1871
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out
var
customChildEvent) ? customChildEvent.Snapshot.State?.Text : null;
1917
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out
var
parentEvent) ? parentEvent.Snapshot.State?.Text : null;
1918
var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out
var
childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null;
1919
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out
var
customChildEvent) ? customChildEvent.Snapshot.State?.Text : null;
1958
await foreach (
var
item in resourceNotificationService.WatchAsync())
2015
await foreach (
var
item in resourceNotificationService.WatchAsync())
2069
await foreach (
var
item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
88
await foreach (
var
resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceCommandAnnotationTests.cs (1)
225
var
resourceEvent = new ResourceEvent(resource, "project-rebuilder", new CustomResourceSnapshot
ResourceCommandServiceTests.cs (2)
1832
Assert.True(resourceNotificationService.TryGetCurrentState(replicaNames[1], out
var
activeReplica));
1839
Assert.True(resourceNotificationService.TryGetCurrentState(replicaNames[0], out
var
inactiveReplica));
ResourceNotificationTests.cs (63)
80
await foreach (
var
item in notificationService.WatchAsync(cts.Token))
89
var
resourceEvent = await watchTask.DefaultTimeout();
114
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
136
Assert.True(notificationService.TryGetCurrentState(resource.Resource.Name, out
var
resourceEvent));
150
Assert.True(notificationService.TryGetCurrentState(resource.Resource.Name, out
var
resourceEvent));
164
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
201
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
213
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellationToken)
215
var values = new List<
ResourceEvent
>();
217
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
270
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
291
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellation)
293
var values = new List<
ResourceEvent
>();
295
await foreach (
var
item in notificationService.WatchAsync(cancellation))
528
var
waitingEvent = await notificationService.WaitForResourceAsync(
541
var
updatedWaitingEvent = await notificationService.WaitForResourceAsync(
556
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
completedWaitingEvent));
632
var
waitingEvent = await notificationService.WaitForResourceAsync(
650
var
updatedWaitingEvent = await notificationService.WaitForResourceAsync(
670
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
completedWaitingEvent));
688
var
waitingEvent = await notificationService.WaitForResourceAsync(
702
var
updatedWaitingEvent = await notificationService.WaitForResourceAsync(
718
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
completedWaitingEvent));
742
var
waitingEvent = await notificationService.WaitForResourceAsync(
789
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
resourceEvent));
827
Assert.True(notificationService.TryGetCurrentState("resource-def456", out
var
notStartedEvent));
867
Assert.True(notificationService.TryGetCurrentState("resource-abc123", out
var
notStartedEvent));
893
var
waitingEvent = await notificationService.WaitForResourceAsync(
932
var
waitingEvent = await notificationService.WaitForResourceAsync(
964
var
waitingEvent = await notificationService.WaitForResourceAsync(
977
var
partialWaitingEvent = await notificationService.WaitForResourceAsync(
992
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
completedWaitingEvent));
1008
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
waitingEvent));
1016
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
runningEvent));
1251
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellationToken)
1253
var values = new List<
ResourceEvent
>();
1255
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
1289
var
firstEvent = values[0];
1294
var
secondEvent = values[1];
1311
async Task<
ResourceEvent
> GetFirstValueAsync(CancellationToken cancellationToken)
1313
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
1329
var
value = await enumerableTask.DefaultTimeout();
1347
async Task<
ResourceEvent
> GetFirstValueAsync(CancellationToken cancellationToken)
1349
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
1365
var
value = await enumerableTask.DefaultTimeout();
1507
var
resourceEvent = await waitTask.DefaultTimeout();
1576
var
resourceEvent = await waitTask.DefaultTimeout();
1604
var
resourceEvent = await notificationService.WaitForResourceHealthyAsync(resource.Name, waitBehavior).DefaultTimeout();
1731
await foreach (
var
resourceEvent in notificationService.WatchAsync())
1873
Assert.True(notificationService.TryGetCurrentState(resourceBuilder.Resource.Name, out
var
resourceEvent));
1918
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
initial));
1922
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
unchanged));
1927
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
changed));
1983
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
initial));
1987
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
unchanged));
2000
Assert.True(notificationService.TryGetCurrentState("myResource", out
var
changed));
2012
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
initial));
2019
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
unchanged));
2035
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
initial));
2038
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
changed));
2064
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
initial));
2070
Assert.True(notificationService.TryGetCurrentState(resource.Name, out
var
changed));
2077
private static string[] GetWaitingForDependencies(
ResourceEvent
resourceEvent)
WithHttpCommandTests.cs (4)
955
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync(
968
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1011
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync(
1026
var
enabledEvent = await app.ResourceNotifications.WaitForResourceAsync(
WithUrlsTests.cs (8)
118
await foreach (
var
notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration))
615
var
resourceEvent = await rns.WaitForResourceAsync(
640
var
resourceEvent = await rns.WaitForResourceAsync(
673
var
resourceEvent = await rns.WaitForResourceAsync(
706
await foreach (
var
notification in rns.WatchAsync().DefaultTimeout(TestConstants.LongTimeoutDuration))
783
var
resourceEvent = await rns.WaitForResourceAsync(
1116
var
resourceEvent = await rns.WaitForResourceAsync(
1168
var
resourceEvent = await rns.WaitForResourceAsync(
Aspire.Hosting.TestUtilities (3)
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Utils\PersistentContainerTestHelpers.cs (2)
129
var
resourceEvent = await resourceNotificationService.WaitForResourceAsync(resourceName, evt =>
157
private static object? GetPropertyValue(
ResourceEvent
resourceEvent, string propertyName) =>
Aspire.Hosting.Valkey (1)
src\Shared\ContainerReplCommand.cs (1)
28
if (!notifications.TryGetCurrentState(context.ResourceName, out
var
resourceEvent) ||
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))