16 writes to WaitForValueTcs
Aspire.Hosting (3)
Orchestrator\ParameterProcessor.cs (3)
50
parameterResource.
WaitForValueTcs
= new(TaskCreationOptions.RunContinuationsAsynchronously);
402
parameterResource.
WaitForValueTcs
= tcs;
423
parameterResource.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (13)
Orchestrator\ParameterProcessorTests.cs (13)
193
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
282
parameterWithMissingValue.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
377
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
429
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
473
secretParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
506
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
545
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
904
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
948
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
981
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1250
connectionStringParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1291
regularParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1335
customParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
67 references to WaitForValueTcs
Aspire.Hosting (7)
ApplicationModel\ParameterResource.cs (3)
48
if (
WaitForValueTcs
?.Task is { IsCompleted: true } valueTask)
99
if (
WaitForValueTcs
is not null)
102
return await
WaitForValueTcs
.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Orchestrator\ParameterProcessor.cs (4)
158
parameterResource.
WaitForValueTcs
?.TrySetResult(value);
175
parameterResource.
WaitForValueTcs
?.TrySetException(ex);
421
if (parameterResource.
WaitForValueTcs
?.Task.IsCompleted ?? false)
426
parameterResource.
WaitForValueTcs
?.TrySetResult(inputValue);
Aspire.Hosting.Tests (60)
Orchestrator\ParameterProcessorTests.cs (58)
42
Assert.NotNull(param.
WaitForValueTcs
);
43
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
45
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task.DefaultTimeout());
68
Assert.NotNull(param.
WaitForValueTcs
);
69
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
71
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task.DefaultTimeout());
118
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
119
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
134
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
135
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
136
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsFaulted);
137
Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.
WaitForValueTcs
.Task.Exception?.InnerException);
152
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
153
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
167
Assert.NotNull(parameterWithError.
WaitForValueTcs
);
168
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsCompleted);
169
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsFaulted);
170
Assert.IsType<InvalidOperationException>(parameterWithError.
WaitForValueTcs
.Task.Exception?.InnerException);
251
Assert.True(param1.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
252
Assert.True(param2.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
253
Assert.True(secretParam.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
254
Assert.Equal("value1", await param1.
WaitForValueTcs
.Task.DefaultTimeout());
255
Assert.Equal("value2", await param2.
WaitForValueTcs
.Task.DefaultTimeout());
256
Assert.Equal("secretValue", await secretParam.
WaitForValueTcs
.Task.DefaultTimeout());
299
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
300
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
597
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
598
Assert.NotNull(referencedParameterResource.
WaitForValueTcs
);
599
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
600
Assert.True(referencedParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
601
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
602
Assert.Equal("referencedValue", await referencedParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
641
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
642
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
643
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
667
Assert.NotNull(parameterResource.
WaitForValueTcs
);
668
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
669
Assert.Equal("envValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
689
Assert.NotNull(parameterResource.
WaitForValueTcs
);
690
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
691
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
711
Assert.NotNull(parameterResource.
WaitForValueTcs
);
712
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
713
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
737
Assert.NotNull(parameterResource.
WaitForValueTcs
);
738
Assert.False(parameterResource.
WaitForValueTcs
.Task.IsCompleted);
771
Assert.NotNull(param.
WaitForValueTcs
);
772
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
808
Assert.NotNull(parameterResource.
WaitForValueTcs
);
809
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
848
Assert.NotNull(parameterResource.
WaitForValueTcs
);
849
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
947
var originalTcs = parameter.
WaitForValueTcs
;
966
Assert.False(parameter.
WaitForValueTcs
!.Task.IsCompleted);
1005
Assert.Equal("newSecretValue", await parameter.
WaitForValueTcs
!.Task.DefaultTimeout());
1228
Assert.NotNull(parameterWithGenerateDefault.
WaitForValueTcs
);
1229
Assert.True(parameterWithGenerateDefault.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1230
Assert.Equal("existingValue", await parameterWithGenerateDefault.
WaitForValueTcs
.Task.DefaultTimeout());
Pipelines\DistributedApplicationPipelineTests.cs (2)
2098
Assert.NotNull(paramResource.
WaitForValueTcs
);
2099
Assert.True(paramResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);