ResourceEvent

ApplicationModel\ResourceNotificationService.cs (4)

490resourceEvent = new ResourceEvent(state.Resource, resourceId, snapshot); 513resourceEvent = new ResourceEvent(m.Value.Resource, m.Key, m.Value.LastSnapshot); 551yield return new ResourceEvent(state.Value.Resource, resourceId, snapshot); 619OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));

DevTunnelResourceBuilderExtensions.cs (1)

690await eventing.PublishAsync<ResourceStoppedEvent>(new(portResource, e.Services, new(portResource, portResource.Name, stoppedSnapshot!)), ct).ConfigureAwait(false);

Eventing\DistributedApplicationBuilderEventingTests.cs (1)

301var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);

ApplicationModel\ResourceCommandService.cs (1)

47if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent))

ApplicationModel\ResourceNotificationService.cs (21)

31private Action<ResourceEvent>? OnResourceUpdated { get; set; } 130await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 186public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 219public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 222var resourceEvent = await WaitForResourceCoreAsync(resourceName, re => ShouldYield(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 275var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 311Func<ILogger, string, string, ResourceEvent, Task> postRunningAction, CancellationToken cancellationToken) 330var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 433/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 438public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 441var resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false); 447private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 451await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 481/// <param name="resourceEvent">When this method returns, contains the <see cref="ResourceEvent"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param> 483public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out ResourceEvent? resourceEvent) 525public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 527var channel = Channel.CreateUnbounded<ResourceEvent>(); 529void WriteToChannel(ResourceEvent resourceEvent) => 557await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ApplicationModel\ResourceStoppedEvent.cs (2)

17public class ResourceStoppedEvent(IResource resource, IServiceProvider services, ResourceEvent resourceEvent) : IDistributedApplicationResourceEvent 30public ResourceEvent ResourceEvent { get; } = resourceEvent;

Backchannel\AppHostRpcTarget.cs (1)

73await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardEventHandlers.cs (1)

726await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

Dashboard\DashboardServiceData.cs (1)

68await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))

Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)

28await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false))

Exec\ExecResourceManager.cs (1)

127if (!_resourceNotificationService.TryGetCurrentState(dcpExecResourceName, out var resourceEvent))

Health\ResourceHealthCheckService.cs (8)

29await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false)) 128ResourceEvent? currentEvent = null; 317public ResourceMonitorState(ILogger logger, ResourceEvent initialEvent, CancellationToken serviceStoppingToken) 330public ResourceEvent LatestEvent { get; private set; } 338public void SetLatestEvent(ResourceEvent resourceEvent) 354internal async Task<bool> DelayAsync(ResourceEvent? currentEvent, TimeSpan delay, CancellationToken cancellationToken) 377private static bool ShouldInterrupt(ResourceEvent currentEvent, ResourceEvent previousEvent)

Orchestrator\ApplicationOrchestrator.cs (2)

404if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var previousResourceEvent)) 425if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var currentResourceEvent))

ResourceBuilderExtensions.cs (1)

2159await foreach (var resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))

ResourceLoggerForwarderService.cs (1)

42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))

AzureBicepProvisionerTests.cs (1)

68await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))

DockerSocketBindMountTests.cs (1)

41var state = await rns.WaitForResourceAsync(

MySqlFunctionalTests.cs (1)

599var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>

PostgresFunctionalTests.cs (1)

578var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>

tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))

Codespaces\CodespacesUrlRewriterTests.cs (1)

79var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(

DistributedApplicationTests.cs (14)

Eventing\DistributedApplicationBuilderEventingTests.cs (1)

301var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);

ExternalServiceTests.cs (3)

298var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 325var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 352var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(

Health\ResourceHealthCheckServiceTests.cs (12)

Orchestrator\ApplicationOrchestratorTests.cs (15)

Orchestrator\ParameterProcessorTests.cs (1)

82await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))

ResourceNotificationTests.cs (19)

50async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 52var values = new List<ResourceEvent>(); 54await foreach (var item in notificationService.WatchAsync(cancellationToken)) 103async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 105var values = new List<ResourceEvent>(); 107await foreach (var item in notificationService.WatchAsync(cancellation)) 445async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 447var values = new List<ResourceEvent>(); 449await foreach (var item in notificationService.WatchAsync(cancellationToken)) 483var firstEvent = values[0]; 488var secondEvent = values[1]; 505async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 507await foreach (var item in notificationService.WatchAsync(cancellationToken)) 523var value = await enumerableTask.DefaultTimeout(); 541async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 543await foreach (var item in notificationService.WatchAsync(cancellationToken)) 559var value = await enumerableTask.DefaultTimeout(); 598var resourceEvent = await waitTask.DefaultTimeout(); 667var resourceEvent = await waitTask.DefaultTimeout();

Utils\LoggerNotificationExtensions.cs (1)

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))

WithHttpCommandTests.cs (2)

384await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token)) 454await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))

WithUrlsTests.cs (5)

385await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 421await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 465await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 554await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token)) 675await foreach (var notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))

tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)

132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))