210 references to ResourceNotifications
Aspire.Hosting.Azure.Tests (21)
AzureCosmosDBEmulatorFunctionalTests.cs (5)
47
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
49
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
53
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
55
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
93
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
AzureEventHubsExtensionsTests.cs (6)
46
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
47
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
51
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
53
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
76
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token);
128
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token);
AzureServiceBusExtensionsTests.cs (6)
95
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
97
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
101
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
103
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
813
await app.
ResourceNotifications
.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token);
814
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (4)
60
await app.
ResourceNotifications
.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token);
61
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
65
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token);
67
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (1)
37
var rns = app.
ResourceNotifications
;
WithDockerfileTests.cs (1)
732
await app.
ResourceNotifications
.WaitForResourceAsync(resourceName, resourceState).WaitAsync(timeout ?? TimeSpan.FromMinutes(3));
Aspire.Hosting.Garnet.Tests (4)
GarnetFunctionalTests.cs (4)
41
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
43
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
47
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
49
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Kafka.Tests (4)
KafkaFunctionalTests.cs (4)
42
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
44
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
48
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
50
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.MongoDB.Tests (4)
MongoDbFunctionalTests.cs (4)
53
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
55
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
59
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
61
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.MySql.Tests (8)
MySqlFunctionalTests.cs (8)
50
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
52
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
56
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
58
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
658
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
733
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(mysql.Resource.Name, cts.Token);
794
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
832
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
Aspire.Hosting.Nats.Tests (4)
NatsFunctionalTests.cs (4)
343
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
345
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
349
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
351
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (4)
OracleFunctionalTests.cs (4)
461
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
463
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
467
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
469
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (14)
PostgresFunctionalTests.cs (14)
53
await app.
ResourceNotifications
.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
56
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
62
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
65
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
129
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token);
168
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(pgWebBuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
234
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token);
296
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token);
408
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
494
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
620
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
661
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
730
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token);
791
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
Aspire.Hosting.Python.Tests (1)
AddPythonAppTests.cs (1)
104
await app.
ResourceNotifications
.WaitForResourceAsync("pyproj", "Finished").WaitAsync(TimeSpan.FromSeconds(30));
Aspire.Hosting.Qdrant.Tests (4)
QdrantFunctionalTests.cs (4)
272
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
274
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
278
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token);
280
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (4)
RabbitMQFunctionalTests.cs (4)
43
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
45
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
49
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
51
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
52
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
54
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
58
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
60
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
616
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token);
617
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);
Aspire.Hosting.SqlServer.Tests (10)
SqlServerFunctionalTests.cs (10)
44
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
46
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
50
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
52
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
179
await app1.
ResourceNotifications
.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token);
264
await app2.
ResourceNotifications
.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token);
376
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
429
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token);
501
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(sqlserver.Resource.Name, cts.Token);
563
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token);
Aspire.Hosting.Testing.Tests (2)
TestingFactoryTests.cs (1)
79
await _app.
ResourceNotifications
.WaitForResourceAsync("mywebapp1").WaitAsync(TimeSpan.FromSeconds(60));
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.
ResourceNotifications
.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (110)
Codespaces\CodespacesUrlRewriterTests.cs (2)
74
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
81
var resourceEvent = await app.
ResourceNotifications
.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (39)
33
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
38
var startingEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
41
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
46
var healthyEvent = await app.
ResourceNotifications
.WaitForResourceHealthyAsync("resource").DefaultTimeout();
73
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
78
var startingEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
81
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
86
var runningEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
93
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("resource").DefaultTimeout();
116
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
121
var startingEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
124
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
129
var runningEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource",
164
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
169
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("resource").DefaultTimeout();
179
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
187
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
193
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("resource").DefaultTimeout();
230
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
234
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout();
271
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
314
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
318
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout();
350
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
381
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
444
await app.
ResourceNotifications
.PublishUpdateAsync(parent.Resource, s => s with
490
await app.
ResourceNotifications
.PublishUpdateAsync(parent.Resource, s => s with
542
await app.
ResourceNotifications
.PublishUpdateAsync(parent.Resource, s => s with
550
await app.
ResourceNotifications
.PublishUpdateAsync(child.Resource, s => s with
586
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
591
var startingEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
594
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
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();
632
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
637
var startingEvent = await app.
ResourceNotifications
.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
640
await app.
ResourceNotifications
.PublishUpdateAsync(resource.Resource, s => s with
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();
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.
ResourceNotifications
.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WaitForTests.cs (53)
32
await app.
ResourceNotifications
.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token);
33
await app.
ResourceNotifications
.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token);
34
await app.
ResourceNotifications
.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token);
107
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
109
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
138
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
140
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
175
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
180
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
216
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
218
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
223
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token);
243
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(
267
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(
298
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(dependency.Resource.Name)
327
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
329
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
334
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token);
361
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
363
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
368
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
371
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
376
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token);
408
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
410
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
415
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
418
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
423
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token);
453
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
458
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
468
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);
500
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token);
505
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
515
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token);
555
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, "Waiting", waitingStateCts.Token);
560
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
571
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token);
609
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
614
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
623
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token);
660
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
663
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, "test0", s => s with
668
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
671
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, "test1", s => s with
676
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token);
713
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
716
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, "test0", s => s with
721
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
724
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, "test1", s => s with
729
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token);
762
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token);
765
await app.
ResourceNotifications
.PublishUpdateAsync(dependency.Resource, s => s with
770
await app.
ResourceNotifications
.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token);
WithHttpCommandTests.cs (15)
189
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
219
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
248
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
293
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
336
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
380
await app.
ResourceNotifications
.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
415
await foreach (var resourceEvent in app.
ResourceNotifications
.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
430
await app.
ResourceNotifications
.PublishUpdateAsync(service.Resource, s => s with
434
await app.
ResourceNotifications
.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
440
await app.
ResourceNotifications
.PublishUpdateAsync(service.Resource, s => s with
444
await app.
ResourceNotifications
.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
484
await foreach (var resourceEvent in app.
ResourceNotifications
.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
499
await app.
ResourceNotifications
.PublishUpdateAsync(service.Resource, s => s with
503
await app.
ResourceNotifications
.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
510
await app.
ResourceNotifications
.PublishUpdateAsync(service.Resource, s => s with
Aspire.Hosting.Valkey.Tests (4)
ValkeyFunctionalTests.cs (4)
220
await app.
ResourceNotifications
.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
222
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token);
226
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token);
228
await app.
ResourceNotifications
.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Yarp.Tests (1)
YarpFunctionalTests.cs (1)
36
await app.
ResourceNotifications
.WaitForResourceHealthyAsync(yarp.Resource.Name, cts.Token);
Aspire.Playground.Tests (3)
Infrastructure\DistributedApplicationExtensions.cs (2)
89
return app.
ResourceNotifications
.WaitForResourceAsync(resourceName, targetState, cancellationToken);
106
return Task.WhenAll(applicationModel.Resources.Select(r => app.
ResourceNotifications
.WaitForResourceAsync(r.Name, r => targetStates?.Contains(r.Snapshot.State?.Text, StringComparer.OrdinalIgnoreCase) is true || r.Snapshot.IsHidden, cancellationToken)));
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (var resourceEvent in app.
ResourceNotifications
.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))