3 instantiations of ResourceEvent
Aspire.Hosting (3)
ApplicationModel\ResourceNotificationService.cs (3)
446
resourceEvent = new
ResourceEvent
(state.Resource, resourceId, snapshot);
484
yield return new
ResourceEvent
(state.Value.Resource, resourceId, snapshot);
542
OnResourceUpdated?.Invoke(new
ResourceEvent
(resource, resourceId, newState));
86 references to ResourceEvent
Aspire.Hosting (35)
ApplicationModel\ResourceCommandService.cs (1)
34
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
ApplicationModel\ResourceNotificationService.cs (20)
30
private Action<
ResourceEvent
>? OnResourceUpdated { get; set; }
129
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
162
var
resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
242
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default)
275
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default)
278
var
resourceEvent = await WaitForResourceCoreAsync(resourceName, re => ShouldYield(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
324
var
resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
403
/// <param name="predicate">A predicate which is evaluated for each <see cref="
ResourceEvent
"/> for the selected resource.</param>
408
public async Task<
ResourceEvent
> WaitForResourceAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
411
var
resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false);
417
private async Task<
ResourceEvent
> WaitForResourceCoreAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
421
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
438
/// <param name="resourceEvent">When this method returns, contains the <see cref="
ResourceEvent
"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param>
440
public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out
ResourceEvent
? resourceEvent)
458
public async IAsyncEnumerable<
ResourceEvent
> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
460
var channel = Channel.CreateUnbounded<
ResourceEvent
>();
462
void WriteToChannel(
ResourceEvent
resourceEvent) =>
490
await foreach (
var
item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
73
await foreach (
var
resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardLifecycleHook.cs (1)
369
await foreach (
var
notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
66
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))
Health\ResourceHealthCheckService.cs (8)
29
await foreach (
var
resourceEvent in resourceEvents.ConfigureAwait(false))
128
ResourceEvent
? currentEvent = null;
311
public ResourceMonitorState(ILogger logger,
ResourceEvent
initialEvent, CancellationToken serviceStoppingToken)
324
public
ResourceEvent
LatestEvent { get; private set; }
332
public void SetLatestEvent(
ResourceEvent
resourceEvent)
348
internal async Task<bool> DelayAsync(
ResourceEvent
? currentEvent, TimeSpan delay, CancellationToken cancellationToken)
371
private static bool ShouldInterrupt(
ResourceEvent
currentEvent,
ResourceEvent
previousEvent)
ResourceBuilderExtensions.cs (1)
1706
await foreach (
var
resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))
ResourceLoggerForwarderService.cs (1)
42
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
64
await foreach (
var
resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
41
var
state = await rns.WaitForResourceAsync(
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
598
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
579
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (45)
Codespaces\CodespacesUrlRewriterTests.cs (1)
81
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (13)
134
var
resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
178
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
179
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
200
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
208
var
dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
253
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
254
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
274
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
281
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
329
ResourceEvent
? notStartedResourceEvent = null;
330
ResourceEvent
? dependentResourceEvent = null;
357
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
364
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
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",
591
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
600
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
607
var
healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
637
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
645
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
653
var
unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
39
await foreach (
var
item in resourceNotificationService.WatchAsync())
86
await foreach (
var
item in resourceNotificationService.WatchAsync())
177
await foreach (
var
item in resourceNotificationService.WatchAsync())
242
await foreach (
var
item in resourceNotificationService.WatchAsync())
293
await foreach (
var
item in resourceNotificationService.WatchAsync())
408
await foreach (
var
item in resourceNotificationService.WatchAsync())
ResourceNotificationTests.cs (6)
51
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellationToken)
53
var values = new List<
ResourceEvent
>();
55
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
104
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellation)
106
var values = new List<
ResourceEvent
>();
108
await foreach (
var
item in notificationService.WatchAsync(cancellation))
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (2)
385
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
455
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
WithUrlsTests.cs (4)
339
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
375
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
463
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
584
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))