573 references to DefaultTimeout
Aspire.Hosting.Tests (573)
AddConnectionStringTests.cs (1)
31
var connectionStringManifest = await ManifestUtils.GetManifest(connectionStringResource).
DefaultTimeout
();
AddParameterTests.cs (5)
104
var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).
DefaultTimeout
();
156
var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).
DefaultTimeout
();
248
var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).
DefaultTimeout
();
305
var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "val")).
DefaultTimeout
();
333
var connectionStringManifest = await ManifestUtils.GetManifest(connectionStringResource).
DefaultTimeout
();
ApplicationModel\EndpointHostHelpersTests.cs (2)
232
.
DefaultTimeout
();
260
.
DefaultTimeout
();
AtsInteractionExportsTests.cs (2)
27
}).
DefaultTimeout
();
54
}).
DefaultTimeout
();
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (48)
43
var result = await target.GetAppHostInfoAsync().
DefaultTimeout
();
111
var ready = await waitTask.
DefaultTimeout
();
149
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
253
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
363
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
418
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
468
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
531
var firstResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
552
var secondResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
606
var firstResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
626
var secondResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
678
var firstResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
697
var secondResult = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
747
var firstResult = await firstConnection.GetResourceSnapshotsAsync().
DefaultTimeout
();
773
var secondResult = await secondConnection.GetResourceSnapshotsAsync().
DefaultTimeout
();
839
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
896
var result = await firstConnection.GetResourceSnapshotsAsync().
DefaultTimeout
();
932
_ = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
945
.
DefaultTimeout
());
984
await target.GetResourceSnapshotsAsync(cts.Token).
DefaultTimeout
();
1002
.
DefaultTimeout
();
1050
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
1106
var before = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "before")).
DefaultTimeout
();
1122
var after = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "after")).
DefaultTimeout
();
1164
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
1237
}).
DefaultTimeout
();
1274
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
1322
}).
DefaultTimeout
();
1367
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
1403
var result = await target.GetResourceSnapshotsAsync().
DefaultTimeout
();
1443
var response = await waitTask.
DefaultTimeout
();
1482
var response = await waitTask.
DefaultTimeout
();
1583
}).
DefaultTimeout
();
2181
var result = await target.GetDashboardUrlsAsync().
DefaultTimeout
();
2302
}).
DefaultTimeout
();
2355
}).
DefaultTimeout
();
2413
}).
DefaultTimeout
();
2484
}).
DefaultTimeout
();
2559
}).
DefaultTimeout
();
2609
}).
DefaultTimeout
();
2668
}).
DefaultTimeout
();
2696
}).
DefaultTimeout
();
2723
}).
DefaultTimeout
();
2747
var result = await target.GetDashboardUrlsAsync().
DefaultTimeout
();
2773
}).
DefaultTimeout
();
2806
}).
DefaultTimeout
();
2839
var result = await target.GetAppHostInformationAsync().
DefaultTimeout
();
2876
var result = await target.GetAppHostInfoAsync().
DefaultTimeout
();
Backchannel\AuxiliaryBackchannelTests.cs (12)
49
var connectedEvent = await connectedEventReceived.Task.
DefaultTimeout
();
136
var bytesRead = await stream.ReadAsync(new byte[1]).AsTask().
DefaultTimeout
();
167
).
DefaultTimeout
();
202
).
DefaultTimeout
();
252
var results = await Task.WhenAll(tasks).
DefaultTimeout
();
287
).
DefaultTimeout
();
369
).
DefaultTimeout
();
410
).
DefaultTimeout
();
495
).
DefaultTimeout
();
536
).
DefaultTimeout
();
579
).
DefaultTimeout
();
621
).
DefaultTimeout
();
Backchannel\GetTerminalInfoAsyncTests.cs (9)
33
new GetTerminalInfoRequest { ResourceName = "nope" }).
DefaultTimeout
();
50
new GetTerminalInfoRequest { ResourceName = "plain" }).
DefaultTimeout
();
114
}).
DefaultTimeout
();
122
}).
DefaultTimeout
();
180
}).
DefaultTimeout
();
242
}).
DefaultTimeout
();
270
var result = await target.GetCapabilitiesAsync().
DefaultTimeout
();
286
() => target.ListTerminalsAsync(new ListTerminalsRequest())).
DefaultTimeout
();
308
var result = await target.ListTerminalsAsync(new ListTerminalsRequest()).
DefaultTimeout
();
BuildOnlyContainerValidationTests.cs (2)
30
() => ExecutePipelineAsync(app)).
DefaultTimeout
();
51
() => ExecutePipelineAsync(app)).
DefaultTimeout
();
ComputeEnvironmentValidationTests.cs (1)
25
() => app.ExecuteBeforeStartHooksAsync(default)).
DefaultTimeout
();
ContainerTunnelTests.cs (4)
38
var response = await clientA.GetAsync("/servicea/").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
40
var body = await response.Content.ReadAsStringAsync().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
77
var response = await clientA.GetAsync("/servicea/").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
79
var body = await response.Content.ReadAsStringAsync().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
Dashboard\DashboardEventHandlersTests.cs (1)
263
.
DefaultTimeout
();
Dashboard\DashboardResourceTests.cs (2)
772
var log = await testLogger.FirstLogTask.
DefaultTimeout
();
798
var manifest = await ManifestUtils.GetManifestOrNull(dashboard).
DefaultTimeout
();
Dashboard\DashboardServiceDataTerminalTests.cs (5)
37
var snapshot = await data.WaitForResourceAsync(resource.Name, _ => true).
DefaultTimeout
();
52
var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).
DefaultTimeout
();
89
var snapshot = await data.WaitForResourceAsync("myapp-ccc", r => HasTerminalProperty(r, "terminal.enabled")).
DefaultTimeout
();
112
var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).
DefaultTimeout
();
137
var snapshot = await data.WaitForResourceAsync("myapp-unknown", r => HasTerminalProperty(r, "terminal.enabled")).
DefaultTimeout
();
Dashboard\DashboardServiceTests.cs (35)
76
var update1 = await writer.ReadNextAsync().
DefaultTimeout
();
81
var update2 = await writer.ReadNextAsync().
DefaultTimeout
();
89
var update3 = await writer.ReadNextAsync().
DefaultTimeout
();
129
var exceedLimitUpdate = await writer.ReadNextAsync().
DefaultTimeout
();
133
var longLinesUpdate1 = await writer.ReadNextAsync().
DefaultTimeout
();
138
var longLinesUpdate2 = await writer.ReadNextAsync().
DefaultTimeout
();
221
}).
DefaultTimeout
();
235
var readUpdateTask = writer.ReadNextAsync().
DefaultTimeout
();
236
var completedTask = await Task.WhenAny(task, readUpdateTask).
DefaultTimeout
();
503
var update = await writer.ReadNextAsync().
DefaultTimeout
();
520
Assert.Equal(result, (await resultTask.
DefaultTimeout
()).Data);
530
Assert.True((await resultTask.
DefaultTimeout
()).Canceled);
575
var update = await writer.ReadNextAsync().
DefaultTimeout
();
609
var update = await writer.ReadNextAsync().
DefaultTimeout
();
628
var promptResult = await prompt.
DefaultTimeout
();
631
var complete = await writer.ReadNextAsync().
DefaultTimeout
();
675
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
737
var update = await writer.ReadNextAsync().
DefaultTimeout
();
751
var result = await resultTask.
DefaultTimeout
();
793
await Assert.ThrowsAnyAsync<Exception>(() => task).
DefaultTimeout
();
835
await Assert.ThrowsAnyAsync<Exception>(() => task).
DefaultTimeout
();
1432
var initial = await responses.ReadNextAsync().
DefaultTimeout
();
1436
var recovery = WatchTerminalsUpdate.Parser.ParseFrom((await responses.ReadNextAsync().
DefaultTimeout
()).ToByteArray());
1455
var change = await responses.ReadNextAsync().
DefaultTimeout
();
1533
var status = await responses.ReadNextAsync().
DefaultTimeout
();
1554
new CloseTerminalRequest { TerminalId = "unknown" }, TestServerCallContext.Create()).
DefaultTimeout
();
1585
new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).
DefaultTimeout
();
1614
new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).
DefaultTimeout
();
1645
var response = await service.CloseTerminal(request, TestServerCallContext.Create()).
DefaultTimeout
();
1650
Assert.NotNull(await service.CloseTerminal(request, TestServerCallContext.Create()).
DefaultTimeout
());
1689
var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).
DefaultTimeout
();
1719
await run.
DefaultTimeout
();
1771
var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).
DefaultTimeout
();
1794
var log = await logs.Reader.ReadAsync().AsTask().
DefaultTimeout
();
1830
var log = await logs.Reader.ReadAsync().AsTask().
DefaultTimeout
();
Dashboard\ResourcePublisherTests.cs (1)
67
var change = Assert.Single(await tcs.Task.
DefaultTimeout
());
Dcp\DcpExecutorTests.cs (13)
135
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => executor.RunApplicationAsync()).
DefaultTimeout
();
2092
Assert.Equal(1, await terminalLogCountAtNotification.Task.
DefaultTimeout
());
2343
var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
2831
var change = await changes.Reader.ReadAsync().AsTask().
DefaultTimeout
();
2873
var change = await changes.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4281
var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4282
var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4330
var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4412
var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4454
var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().
DefaultTimeout
();
4633
var failedContext = await tcs.Task.
DefaultTimeout
();
9463
var allocatedEndpoint = await endpoint.AllAllocatedEndpoints.Single(x => x.NetworkID == network).Snapshot.GetValueAsync().
DefaultTimeout
();
10355
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => startTask).
DefaultTimeout
();
DistributedApplicationTests.cs (49)
80
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
125
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
154
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
353
await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
356
await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
405
await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
458
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
478
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
499
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
787
await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
800
var pidText = await clientB.GetStringAsync(url).
DefaultTimeout
();
837
var list = await s.ListAsync<Container>().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
894
var list = await s.ListAsync<Container>().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
938
var list = await s.ListAsync<Container>().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1013
var list = await s.ListAsync<Container>().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1148
r => r.Spec.Env != null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1188
r => r.Spec.Env != null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1229
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1237
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1269
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1276
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1281
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).
DefaultTimeout
(TestConstants.LongTimeoutDuration);
1311
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1314
var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1317
var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1392
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1429
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1524
r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1553
$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1581
$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1610
$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1616
var containerVolume = Assert.Single(await s.ListAsync<ContainerVolume>().
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout));
1713
var allocatedEndpoint = await allocatedEndpointSnapshot.Snapshot.GetValueAsync().
DefaultTimeout
();
1738
var result = await client.GetStringAsync("pid").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1750
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1812
var value = await client.GetStringAsync($"{httpsEndpoint}urls", token).
DefaultTimeout
();
1855
await clientA.GetStringAsync("/").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1858
var exeList = await s.ListAsync<Executable>().
DefaultTimeout
();
1867
var list = await s.ListAsync<Container>().
DefaultTimeout
();
1880
.
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
1929
await clientA.GetStringAsync("/").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1933
var serviceList = await s.ListAsync<Service>().
DefaultTimeout
();
1936
var exeList = await s.ListAsync<Executable>().
DefaultTimeout
();
1945
var list = await s.ListAsync<Container>().
DefaultTimeout
();
1958
.
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
2022
var networks = await s.ListAsync<ContainerNetwork>().
DefaultTimeout
();
2064
.
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
2073
.
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
2249
.
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
DotnetProgramPublishingTests.cs (4)
273
() => ExecuteBuildPipelineAsync(app, WellKnownPipelineSteps.Build)).
DefaultTimeout
();
346
() => ExecuteBuildPipelineAsync(app, "build-program")).
DefaultTimeout
();
391
var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().
DefaultTimeout
();
417
manager.BuildImageAsync(resource.Resource, TestContext.Current.CancellationToken)).
DefaultTimeout
();
ExecutableResourceTests.cs (1)
68
var manifest = await ManifestUtils.GetManifest(exe2.Resource).
DefaultTimeout
();
ExternalServiceTests.cs (4)
343
).
DefaultTimeout
();
370
).
DefaultTimeout
();
397
).
DefaultTimeout
();
471
CancellationToken.None).
DefaultTimeout
();
Health\FriendlyHealthCheckErrorMessagesTests.cs (4)
39
cts.Token).
DefaultTimeout
();
79
cts.Token).
DefaultTimeout
();
118
CancellationToken.None).
DefaultTimeout
();
154
CancellationToken.None).
DefaultTimeout
();
Health\ResourceHealthCheckServiceTests.cs (26)
29
await using var app = await builder.BuildAsync().
DefaultTimeout
();
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
();
69
await using var app = await builder.BuildAsync().
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
();
93
await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").
DefaultTimeout
();
112
await using var app = await builder.BuildAsync().
DefaultTimeout
();
121
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).
DefaultTimeout
();
130
e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).
DefaultTimeout
();
157
await using var app = await builder.BuildAsync().
DefaultTimeout
();
168
await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").
DefaultTimeout
();
192
await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").
DefaultTimeout
();
233
await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).
DefaultTimeout
();
354
var @event = await blockAssert.Task.
DefaultTimeout
();
449
await Task.WhenAll([resourceReadyEventFired.Task]).
DefaultTimeout
();
551
var parentReadyEvent = await parentReady.Task.
DefaultTimeout
();
554
var childReadyEvent = await childReady.Task.
DefaultTimeout
();
578
await using var app = await builder.BuildAsync().
DefaultTimeout
();
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
();
624
await using var app = await builder.BuildAsync().
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
();
HealthCheckTests.cs (2)
143
await rns.WaitForResourceHealthyAsync(resource.Resource.Name).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestLongTimeout);
168
}).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
InteractionServiceTests.cs (23)
37
var result = await resultTask.
DefaultTimeout
();
62
var result = await resultTask.
DefaultTimeout
();
101
var result1 = await resultTask1.
DefaultTimeout
();
109
var result2 = await resultTask2.
DefaultTimeout
();
115
var result3 = await resultTask3.
DefaultTimeout
();
148
Assert.True((await resultTask1.
DefaultTimeout
()).Data);
152
Assert.Equivalent(result1, await completedInteraction1.CompletionTcs.Task.
DefaultTimeout
());
156
Assert.False((await resultTask2.
DefaultTimeout
()).Data);
160
Assert.Equivalent(result2, await completedInteraction2.CompletionTcs.Task.
DefaultTimeout
());
171
() => interactionService.PromptConfirmationAsync("Are you sure?", "Confirmation")).
DefaultTimeout
();
173
() => interactionService.PromptNotificationAsync("Are you sure?", "Confirmation")).
DefaultTimeout
();
175
() => interactionService.PromptMessageBoxAsync("Are you sure?", "Confirmation")).
DefaultTimeout
();
177
() => interactionService.PromptProgressAsync("Please wait", new ProgressInteractionOptions { Title = "Working..." })).
DefaultTimeout
();
456
var result = await resultTask.
DefaultTimeout
();
874
var result = await resultTask.
DefaultTimeout
();
1056
var result = await resultTask.
DefaultTimeout
();
1143
}).
DefaultTimeout
();
1176
var result = await resultTask.
DefaultTimeout
();
1212
var result = await resultTask.
DefaultTimeout
();
1246
var result = await resultTask.
DefaultTimeout
();
1266
var result = await resultTask.
DefaultTimeout
();
1287
var result = await resultTask.
DefaultTimeout
();
1306
await resultTask.
DefaultTimeout
();
KestrelConfigTests.cs (4)
177
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
219
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
288
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
308
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (5)
40
var logs = await ReadLogsAsync(loggers, host, expected: 2).
DefaultTimeout
();
80
var logs = await ReadLogsAsync(loggers, host, expected: 2).
DefaultTimeout
();
114
var current = await ReadCurrentSnapshotAsync(notifications, host).
DefaultTimeout
();
154
var logs = await ReadLogsAsync(loggers, host, expected: 1).
DefaultTimeout
();
191
await ReadLogsAsync(loggers, host, expected: 2).
DefaultTimeout
();
ManifestGenerationTests.cs (5)
104
var redisManifest = await ManifestUtils.GetManifest(redis.Resource).
DefaultTimeout
();
547
var manifest = await ManifestUtils.GetManifest(param.Resource).
DefaultTimeout
();
573
var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).
DefaultTimeout
();
616
var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).
DefaultTimeout
();
667
var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).
DefaultTimeout
();
Orchestrator\ApplicationOrchestratorTests.cs (6)
741
TestContext.Current.CancellationToken).
DefaultTimeout
();
799
TestContext.Current.CancellationToken).
DefaultTimeout
();
850
TestContext.Current.CancellationToken).
DefaultTimeout
();
904
TestContext.Current.CancellationToken).
DefaultTimeout
();
912
TestContext.Current.CancellationToken).
DefaultTimeout
();
1099
TestContext.Current.CancellationToken).
DefaultTimeout
();
Orchestrator\ParameterProcessorTests.cs (38)
47
Assert.Equal(param.Value, await param.WaitForValueTcs.Task.
DefaultTimeout
());
73
Assert.Equal(param.Value, await param.WaitForValueTcs.Task.
DefaultTimeout
());
256
Assert.Equal("value1", await param1.WaitForValueTcs.Task.
DefaultTimeout
());
257
Assert.Equal("value2", await param2.WaitForValueTcs.Task.
DefaultTimeout
());
258
Assert.Equal("secretValue", await secretParam.WaitForValueTcs.Task.
DefaultTimeout
());
310
await parameterProcessor.SetParameterCoreAsync(parameterWithMissingValue, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).
DefaultTimeout
();
342
var logs = await logsTask.
DefaultTimeout
();
366
var logs = await logsTask.
DefaultTimeout
();
409
var logs = await logsTask.
DefaultTimeout
();
612
Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
613
Assert.Equal("referencedValue", await referencedParameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
654
Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
680
Assert.Equal("envValue", await parameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
702
Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
724
Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.
DefaultTimeout
());
974
var section = await deploymentStateManager.AcquireSectionAsync(parameter.ConfigurationKey).
DefaultTimeout
();
1045
var section = await deploymentStateManager.AcquireSectionAsync(parameter.ConfigurationKey).
DefaultTimeout
();
1098
var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("newValue"), CancellationToken.None).
DefaultTimeout
();
1115
var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments(value: null), CancellationToken.None).
DefaultTimeout
();
1134
var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).
DefaultTimeout
();
1150
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("firstValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1155
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("secondValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1225
var result = await parameterProcessor.SetParameterCoreAsync(secretParam, CreateSetParameterArguments("replacement-secret"), CancellationToken.None).
DefaultTimeout
();
1389
Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task.
DefaultTimeout
());
1526
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1529
var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1533
var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").
DefaultTimeout
();
1545
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1547
var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, new InteractionInputCollection([]), CancellationToken.None).
DefaultTimeout
();
1562
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1564
var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1583
await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).
DefaultTimeout
();
1584
await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).
DefaultTimeout
();
1586
var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().
DefaultTimeout
();
1591
var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().
DefaultTimeout
();
1634
var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").
DefaultTimeout
();
1637
var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().
DefaultTimeout
();
1641
var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().
DefaultTimeout
();
Pipelines\DistributedApplicationPipelineTests.cs (29)
341
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
356
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
386
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
407
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
554
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
575
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
636
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
658
var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
693
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
737
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
769
await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
800
await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
831
await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
870
await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
893
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
918
var exception = await Assert.ThrowsAsync<ProcessFailedException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
1267
await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
1830
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).
DefaultTimeout
();
2242
var steps = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2295
() => pipeline.ExecuteStepSequentiallyAsync("step", CreateDeployingContext(app))).
DefaultTimeout
();
2314
var first = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2315
var second = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2337
() => pipeline.ResolveStepsAsync(CreateDeployingContext(app))).
DefaultTimeout
();
2364
() => pipeline.ResolveStepsAsync(CreateDeployingContext(app))).
DefaultTimeout
();
2384
var steps = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2405
var steps = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2426
await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
2536
await cloned.ResolveStepsAsync(context).
DefaultTimeout
();
2546
var resolved = await pipeline.ResolveStepsAsync(context).
DefaultTimeout
();
ProjectResourceTests.cs (4)
37
var projectDetails = await PrepareProjectWithTrailingCommasInLaunchSettingsAsync(workspace.WorkspaceRoot.FullName).
DefaultTimeout
();
81
var projectDetails = await PrepareProjectWithMalformedLaunchSettingsAsync(workspace.WorkspaceRoot.FullName).
DefaultTimeout
();
602
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
650
var manifest = await ManifestUtils.GetManifest(resource).
DefaultTimeout
();
PublishAsConnectionStringTests.cs (1)
24
var manifest = await ManifestUtils.GetManifest(redis.Resource).
DefaultTimeout
();
PublishAsDockerfileTests.cs (5)
31
var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).
DefaultTimeout
();
77
var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).
DefaultTimeout
();
126
var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).
DefaultTimeout
();
175
var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).
DefaultTimeout
();
235
var manifest = await ManifestUtils.GetManifest(project.Resource, manifestDirectory: path).
DefaultTimeout
();
Publishing\ContainerRuntimeReadinessTests.cs (9)
38
.EnsureRunningAsync(runtime, TestContext.Current.CancellationToken)).
DefaultTimeout
();
57
var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().
DefaultTimeout
();
87
var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().
DefaultTimeout
();
90
var exception = await Assert.ThrowsAsync<DistributedApplicationException>(() => check).
DefaultTimeout
();
114
readiness.EnsureRunningAsync(runtime, TestContext.Current.CancellationToken)).
DefaultTimeout
();
131
var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().
DefaultTimeout
();
136
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => second).
DefaultTimeout
();
164
var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().
DefaultTimeout
();
169
var exception = await Assert.ThrowsAsync<DistributedApplicationException>(() => check).
DefaultTimeout
();
Publishing\DockerContainerRuntimeTests.cs (1)
145
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => buildTask).
DefaultTimeout
();
Publishing\DotnetProgramArchiveTests.cs (2)
186
() => BuildAsync(app, resource.Resource, false, cancellation.Token)).
DefaultTimeout
();
228
() => BuildAsync(app, resource.Resource, false, cancellation.Token)).
DefaultTimeout
();
Publishing\PipelineActivityReporterTests.cs (5)
584
var promptResult = await promptTask.
DefaultTimeout
();
613
var promptResult = await promptTask.
DefaultTimeout
();
642
var promptResult = await promptTask.
DefaultTimeout
();
673
var result = await promptTask.
DefaultTimeout
();
746
var notificationResult = await notificationTask.
DefaultTimeout
();
Publishing\ResourceContainerImageManagerTests.cs (2)
1237
var result = await pendingResult.WaitAsync(TestContext.Current.CancellationToken).
DefaultTimeout
();
1301
var result = await pendingResult.WaitAsync(TestContext.Current.CancellationToken).
DefaultTimeout
();
ResourceCommandServiceTests.cs (13)
642
CancellationToken.None).
DefaultTimeout
();
1038
CancellationToken.None).
DefaultTimeout
();
1128
CancellationToken.None).
DefaultTimeout
();
1203
CancellationToken.None).
DefaultTimeout
();
1250
CancellationToken.None).
DefaultTimeout
();
1297
CancellationToken.None).
DefaultTimeout
();
1393
var result = await resultTask.
DefaultTimeout
();
1471
CancellationToken.None).
DefaultTimeout
();
1526
CancellationToken.None).
DefaultTimeout
();
1560
CancellationToken.None).
DefaultTimeout
();
1594
CancellationToken.None).
DefaultTimeout
();
1865
var result = await resultTask.
DefaultTimeout
();
1915
var result = await resultTask.
DefaultTimeout
();
ResourceLoggerServiceTests.cs (15)
36
var allLogs = await logsLoop.
DefaultTimeout
();
49
allLogs = await logsLoop.
DefaultTimeout
();
80
var allLogs = await logsLoop.
DefaultTimeout
();
91
allLogs = await logsLoop.
DefaultTimeout
();
117
var allLogs = await logsLoop.
DefaultTimeout
();
130
allLogs = await logsLoop.
DefaultTimeout
();
144
allLogs = await logsLoop.
DefaultTimeout
();
169
var allLogs = await logsLoop.
DefaultTimeout
();
178
allLogs = await logsLoop.
DefaultTimeout
();
188
allLogs = await logsLoop.
DefaultTimeout
();
207
allLogs = await logsLoop.
DefaultTimeout
();
241
var allLogs = await logsLoop.
DefaultTimeout
();
701
var allLogs = await watchTask.
DefaultTimeout
();
732
var allLogs = await watchTask.
DefaultTimeout
();
780
var allSubscribers = await watchTask.
DefaultTimeout
();
ResourceNotificationTests.cs (29)
89
var resourceEvent = await watchTask.
DefaultTimeout
();
126
var values = await enumerableTask.
DefaultTimeout
();
206
var values = await enumerableTask.
DefaultTimeout
();
303
var reachedState = await waitTask.
DefaultTimeout
();
318
var reachedState = await waitTask.
DefaultTimeout
();
354
}).
DefaultTimeout
();
375
cts.Token).
DefaultTimeout
();
388
cts.Token).
DefaultTimeout
();
423
cts.Token).
DefaultTimeout
();
441
cts.Token).
DefaultTimeout
();
479
cts.Token).
DefaultTimeout
();
493
cts.Token).
DefaultTimeout
();
532
cts.Token).
DefaultTimeout
();
612
cts.Token).
DefaultTimeout
();
683
cts.Token).
DefaultTimeout
();
722
cts.Token).
DefaultTimeout
();
755
cts.Token).
DefaultTimeout
();
768
cts.Token).
DefaultTimeout
();
832
}).
DefaultTimeout
();
859
TestContext.Current.CancellationToken).
DefaultTimeout
();
866
}).
DefaultTimeout
();
885
}).
DefaultTimeout
();
902
}).
DefaultTimeout
();
1071
var values = await enumerableTask.
DefaultTimeout
();
1116
var value = await enumerableTask.
DefaultTimeout
();
1152
var value = await enumerableTask.
DefaultTimeout
();
1294
var resourceEvent = await waitTask.
DefaultTimeout
();
1333
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => waitTask.
DefaultTimeout
());
1363
var resourceEvent = await waitTask.
DefaultTimeout
();
Terminals\Hex1bAspireTerminalTests.cs (3)
75
var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => operation).
DefaultTimeout
();
120
() => terminal.SendKeyAsync(AspireTerminalKey.Enter, cts.Token)).
DefaultTimeout
();
520
await run.
DefaultTimeout
();
Terminals\InteractionServiceTerminalTests.cs (16)
123
var result = await prompt.
DefaultTimeout
();
142
() => terminals.AttachAsync(terminal.Id, Stream.Null, _ => Task.CompletedTask, CancellationToken.None)).
DefaultTimeout
();
146
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
172
var result = await prompt.
DefaultTimeout
();
213
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
264
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
290
Assert.True(await firstUpdate.
DefaultTimeout
());
297
Assert.Same(failure, await Assert.ThrowsAsync<InvalidOperationException>(() => prompt).
DefaultTimeout
());
302
Assert.True((await prompt.
DefaultTimeout
()).Data);
320
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
322
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
331
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
335
await second.
DefaultTimeout
();
379
Assert.Equal(cancel, (await prompt.
DefaultTimeout
()).Canceled);
412
Assert.True((await prompt.
DefaultTimeout
()).Canceled);
429
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => prompt).
DefaultTimeout
();
Terminals\ResourceAspireTerminalTests.cs (6)
63
() => terminal.WaitForTextAsync("text-the-workload-never-writes", TimeSpan.FromSeconds(1))).
DefaultTimeout
();
75
await Assert.ThrowsAnyAsync<Exception>(() => terminal.SendTextAsync("hello")).
DefaultTimeout
();
96
await Assert.ThrowsAnyAsync<Exception>(() => terminal.SendTextAsync("not-delivered")).
DefaultTimeout
();
136
using var peer = await listener.AcceptAsync().
DefaultTimeout
();
140
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => canceledCall).
DefaultTimeout
();
144
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => otherCall).
DefaultTimeout
();
Terminals\ResourceTerminalCatalogTests.cs (1)
217
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => automation).
DefaultTimeout
();
Terminals\TerminalClientStreamTests.cs (3)
29
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => read).
DefaultTimeout
();
40
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => write).
DefaultTimeout
();
49
Assert.Equal(1, await peer.ReadAsync(buffer).AsTask().
DefaultTimeout
());
Terminals\TerminalServiceTests.cs (23)
70
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
357
() => service.AttachAsync("does-not-exist", stream, _ => Task.CompletedTask, CancellationToken.None)).
DefaultTimeout
();
385
Assert.True(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
403
Assert.True(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
430
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
438
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
466
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
484
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
505
Assert.True(await updates.MoveNextAsync().AsTask().
DefaultTimeout
());
524
Assert.True(await fastUpdates.MoveNextAsync().AsTask().
DefaultTimeout
());
531
Assert.True(await slowUpdates.MoveNextAsync().AsTask().
DefaultTimeout
());
549
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => updates.MoveNextAsync().AsTask()).
DefaultTimeout
();
562
Assert.False(await next.
DefaultTimeout
());
644
Assert.True(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
724
Assert.Same(expected, await Assert.ThrowsAsync<IOException>(() => disposal).
DefaultTimeout
());
726
Assert.Same(expected, await Assert.ThrowsAsync<IOException>(() => terminal.DisposeAsync().AsTask()).
DefaultTimeout
());
754
Assert.True(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
761
Assert.False(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
818
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => stop).
DefaultTimeout
();
869
Assert.Equal(descriptor.Id, (await create.
DefaultTimeout
()).Id);
885
await create.
DefaultTimeout
();
906
Assert.False(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
968
Assert.False(await changes.MoveNextAsync().AsTask().
DefaultTimeout
());
Utils\TestAppHostTerminalViewer.cs (3)
52
var completed = await Task.WhenAny(viewer._connected.Task, viewer._run, viewer._attachment).
DefaultTimeout
();
72
var connection = await _connected.Task.
DefaultTimeout
();
77
.Build().ApplyAsync(_client, _clientCts.Token).
DefaultTimeout
();
WithEndpointTests.cs (11)
450
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
478
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
505
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
532
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
559
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
586
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
613
var manifest = await ManifestUtils.GetManifest(container.Resource).
DefaultTimeout
();
644
var manifest = await ManifestUtils.GetManifest(project.Resource).
DefaultTimeout
();
712
var manifest = await ManifestUtils.GetManifest(project.Resource).
DefaultTimeout
();
737
var manifests = await ManifestUtils.GetManifests([container0.Resource, container1.Resource]).
DefaultTimeout
();
867
var manifest = await ManifestUtils.GetManifest(project.Resource).
DefaultTimeout
();
WithEnvironmentTests.cs (1)
168
)).
DefaultTimeout
();
WithHttpCommandTests.cs (20)
145
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
387
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", arguments).
DefaultTimeout
();
457
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
482
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", cts.Token).
DefaultTimeout
();
514
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
549
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
636
var result = await app.ResourceCommands.ExecuteCommandAsync(serviceB.Resource, "mycommand").
DefaultTimeout
();
680
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
724
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
788
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", arguments).
DefaultTimeout
();
817
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
843
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
870
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
898
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
925
var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").
DefaultTimeout
();
957
e => e.Snapshot.State?.Text == KnownResourceStates.Starting).
DefaultTimeout
();
971
e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Enabled).
DefaultTimeout
();
1014
e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Hidden).
DefaultTimeout
();
1028
e => e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Enabled).
DefaultTimeout
();
1070
e.Snapshot.Commands.FirstOrDefault(c => c.Name == commandName)?.State == ResourceCommandState.Enabled).
DefaultTimeout
();
WithProcessCommandTests.cs (42)
124
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-command").
DefaultTimeout
();
190
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "options-callback-command", arguments).
DefaultTimeout
();
269
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-command", arguments).
DefaultTimeout
();
313
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-accepted-exit-code").
DefaultTimeout
();
334
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-process-spec").
DefaultTimeout
();
384
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "echo-argument", arguments).
DefaultTimeout
();
450
}).
DefaultTimeout
();
488
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "async-factory").
DefaultTimeout
();
522
var firstResult = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "repeat").
DefaultTimeout
();
523
var secondResult = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "repeat").
DefaultTimeout
();
566
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "many-lines").
DefaultTimeout
();
599
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "display-immediately").
DefaultTimeout
();
623
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "no-output").
DefaultTimeout
();
645
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "fail-no-output").
DefaultTimeout
();
673
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "accepted-exit-code").
DefaultTimeout
();
711
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "failure-display-immediately").
DefaultTimeout
();
735
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "log-output").
DefaultTimeout
();
742
var logs = await ConsoleLoggingTestHelpers.WatchForLogsAsync(loggerService, 4, resource.Resource).
DefaultTimeout
();
791
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "custom-result").
DefaultTimeout
();
833
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "ordered-output").
DefaultTimeout
();
862
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "fail").
DefaultTimeout
();
898
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "argument-fidelity").
DefaultTimeout
();
922
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "stdin").
DefaultTimeout
();
945
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "path-executable").
DefaultTimeout
();
969
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "working-directory").
DefaultTimeout
();
997
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "environment").
DefaultTimeout
();
1023
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "invalid-environment-name").
DefaultTimeout
();
1049
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-environment-value").
DefaultTimeout
();
1087
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-options").
DefaultTimeout
();
1125
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-accepted-exit-code").
DefaultTimeout
();
1150
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-default-options").
DefaultTimeout
();
1213
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, $"invalid-export-{i}").
DefaultTimeout
();
1260
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "default-success-exit-codes").
DefaultTimeout
();
1284
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "environment-inheritance").
DefaultTimeout
();
1307
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "missing").
DefaultTimeout
();
1331
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "process-task-failure").
DefaultTimeout
();
1354
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-process-spec").
DefaultTimeout
();
1380
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-exception").
DefaultTimeout
();
1404
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-argument").
DefaultTimeout
();
1442
var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "validation-failure").
DefaultTimeout
();
1474
await processRunner.RunStarted.Task.
DefaultTimeout
();
1477
var result = await commandTask.
DefaultTimeout
();
WithReferenceTests.cs (2)
306
}).
DefaultTimeout
();
342
}).
DefaultTimeout
();
WithUrlsTests.cs (13)
130
Assert.NotNull(await tcs.Task.
DefaultTimeout
());
390
e => e.Snapshot.Urls.Length == 1).
DefaultTimeout
();
415
e => e.Snapshot.Urls.Length == 3).
DefaultTimeout
();
450
&& e.Snapshot.Urls.All(url => !url.IsInactive)).
DefaultTimeout
();
674
e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).
DefaultTimeout
();
1066
default).
DefaultTimeout
();
1071
resourceBClient.GetStringAsync("/")).
DefaultTimeout
();
1116
default).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1123
var startResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StartCommand).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1126
Assert.Equal("Hello World!", await resourceAClient.GetStringAsync("/").
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout));
1131
default).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1134
var stopResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StopCommand).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);
1140
default).
DefaultTimeout
(TestConstants.DefaultOrchestratorTestTimeout);