9 writes to WaitForValueTcs
Aspire.Hosting (1)
Orchestrator\ParameterProcessor.cs (1)
42
parameterResource.
WaitForValueTcs
= new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (8)
Orchestrator\ParameterProcessorTests.cs (8)
186
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
275
parameterWithMissingValue.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
370
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
419
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
460
secretParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
875
connectionStringParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
914
regularParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
956
customParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
62 references to WaitForValueTcs
Aspire.Hosting (5)
ApplicationModel\ParameterResource.cs (2)
87
if (
WaitForValueTcs
is not null)
90
return await
WaitForValueTcs
.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Orchestrator\ParameterProcessor.cs (3)
168
parameterResource.
WaitForValueTcs
?.TrySetResult(value);
185
parameterResource.
WaitForValueTcs
?.TrySetException(ex);
306
parameter.
WaitForValueTcs
?.TrySetResult(inputValue);
Aspire.Hosting.Tests (57)
Orchestrator\ParameterProcessorTests.cs (55)
39
Assert.NotNull(param.
WaitForValueTcs
);
40
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
42
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task);
65
Assert.NotNull(param.
WaitForValueTcs
);
66
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
68
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task);
115
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
116
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
131
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
132
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
133
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsFaulted);
134
Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.
WaitForValueTcs
.Task.Exception?.InnerException);
149
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
150
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
164
Assert.NotNull(parameterWithError.
WaitForValueTcs
);
165
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsCompleted);
166
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsFaulted);
167
Assert.IsType<InvalidOperationException>(parameterWithError.
WaitForValueTcs
.Task.Exception?.InnerException);
244
Assert.True(param1.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
245
Assert.True(param2.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
246
Assert.True(secretParam.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
247
Assert.Equal("value1", await param1.
WaitForValueTcs
.Task);
248
Assert.Equal("value2", await param2.
WaitForValueTcs
.Task);
249
Assert.Equal("secretValue", await secretParam.
WaitForValueTcs
.Task);
292
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
293
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
506
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
507
Assert.NotNull(referencedParameterResource.
WaitForValueTcs
);
508
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
509
Assert.True(referencedParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
510
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task);
511
Assert.Equal("referencedValue", await referencedParameterResource.
WaitForValueTcs
.Task);
550
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
551
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
552
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task);
576
Assert.NotNull(parameterResource.
WaitForValueTcs
);
577
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
578
Assert.Equal("envValue", await parameterResource.
WaitForValueTcs
.Task);
598
Assert.NotNull(parameterResource.
WaitForValueTcs
);
599
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
600
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task);
620
Assert.NotNull(parameterResource.
WaitForValueTcs
);
621
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
622
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task);
646
Assert.NotNull(parameterResource.
WaitForValueTcs
);
647
Assert.False(parameterResource.
WaitForValueTcs
.Task.IsCompleted);
680
Assert.NotNull(param.
WaitForValueTcs
);
681
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
717
Assert.NotNull(parameterResource.
WaitForValueTcs
);
718
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
757
Assert.NotNull(parameterResource.
WaitForValueTcs
);
758
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
855
Assert.NotNull(parameterWithGenerateDefault.
WaitForValueTcs
);
856
Assert.True(parameterWithGenerateDefault.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
857
Assert.Equal("existingValue", await parameterWithGenerateDefault.
WaitForValueTcs
.Task);
Pipelines\DistributedApplicationPipelineTests.cs (2)
2094
Assert.NotNull(paramResource.
WaitForValueTcs
);
2095
Assert.True(paramResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);