30 writes to WaitForValueTcs
Aspire.Hosting (4)
ApplicationModel\ParameterResource.cs (4)
135
WaitForValueTcs
= waitForValueTcs = CreateWaitForValueTcs();
141
WaitForValueTcs
= waitForValueTcs = CreateWaitForValueTcs();
489
return
WaitForValueTcs
??= CreateWaitForValueTcs();
497
WaitForValueTcs
= waitForValueTcs = CreateWaitForValueTcs();
Aspire.Hosting.Tests (26)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (15)
438
passwordParameter.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
485
topLevelParameter.Resource.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
487
referencedParameter.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
533
secretA.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
537
secretB.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
615
secretA.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
619
secretB.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
690
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
727
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
761
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
795
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
857
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
918
coldSecret.Resource.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1068
secret.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1120
secret.
WaitForValueTcs
= waitForValueTcs;
Orchestrator\ParameterProcessorTests.cs (11)
272
param.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
549
parameter.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
601
param.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
645
secretParam.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
678
param.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
717
param.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1257
parameter.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1274
parameter.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1844
connectionStringParam.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1885
regularParam.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
1929
customParam.
WaitForValueTcs
= new TaskCompletionSource<string?>(TaskCreationOptions.RunContinuationsAsynchronously);
83 references to WaitForValueTcs
Aspire.Hosting (7)
ApplicationModel\ParameterResource.cs (5)
75
var waitForValueTcs =
WaitForValueTcs
;
125
if (
WaitForValueTcs
is { } waitForValueTcs)
207
var waitForValueTcs =
WaitForValueTcs
;
538
if (
WaitForValueTcs
is not null)
541
return await
WaitForValueTcs
.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1265
if (parameter.
WaitForValueTcs
is { } waitForValueTcs)
Backchannel\SecretRedactionHistory.cs (1)
32
/// path swaps a completed <see cref="ParameterResource.
WaitForValueTcs
"/> for a new one
Aspire.Hosting.Tests (76)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (13)
439
passwordParameter.
WaitForValueTcs
.SetResult("generated-s3cr3t");
486
topLevelParameter.Resource.
WaitForValueTcs
.SetResult("top-level-secret");
488
referencedParameter.
WaitForValueTcs
.SetResult("referenced-secret");
534
secretA.
WaitForValueTcs
.SetResult("value-a");
538
secretB.
WaitForValueTcs
.SetResult("value-b");
616
secretA.
WaitForValueTcs
.SetResult("value-a");
620
secretB.
WaitForValueTcs
.SetResult("value-b");
691
secret.
WaitForValueTcs
.SetResult("value-a");
728
secret.
WaitForValueTcs
.SetResult("value-b");
762
secret.
WaitForValueTcs
.SetResult("value-a");
796
secret.
WaitForValueTcs
.SetResult("value-b");
843
secret.
WaitForValueTcs
!.TrySetResult("leaked-during-mcp");
919
coldSecret.Resource.
WaitForValueTcs
.SetResult("value-b");
Orchestrator\ParameterProcessorTests.cs (61)
43
Assert.NotNull(param.
WaitForValueTcs
);
44
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
46
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task.DefaultTimeout());
69
Assert.NotNull(param.
WaitForValueTcs
);
70
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
72
Assert.Equal(param.Value, await param.
WaitForValueTcs
.Task.DefaultTimeout());
119
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
120
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
138
Assert.NotNull(parameter.
WaitForValueTcs
);
139
Assert.True(parameter.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
140
Assert.Null(await parameter.
WaitForValueTcs
.Task.DefaultTimeout());
193
Assert.NotNull(parameter.
WaitForValueTcs
);
194
Assert.True(parameter.
WaitForValueTcs
.Task.IsFaulted);
213
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
214
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
215
Assert.True(parameterWithMissingValue.
WaitForValueTcs
.Task.IsFaulted);
216
Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.
WaitForValueTcs
.Task.Exception?.InnerException);
231
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
232
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
246
Assert.NotNull(parameterWithError.
WaitForValueTcs
);
247
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsCompleted);
248
Assert.True(parameterWithError.
WaitForValueTcs
.Task.IsFaulted);
249
Assert.IsType<InvalidOperationException>(parameterWithError.
WaitForValueTcs
.Task.Exception?.InnerException);
330
Assert.True(param1.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
331
Assert.True(param2.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
332
Assert.True(secretParam.
WaitForValueTcs
!.Task.IsCompletedSuccessfully);
333
Assert.Equal("value1", await param1.
WaitForValueTcs
.Task.DefaultTimeout());
334
Assert.Equal("value2", await param2.
WaitForValueTcs
.Task.DefaultTimeout());
335
Assert.Equal("secretValue", await secretParam.
WaitForValueTcs
.Task.DefaultTimeout());
382
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
383
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
769
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
770
Assert.NotNull(referencedParameterResource.
WaitForValueTcs
);
771
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
772
Assert.True(referencedParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
773
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
774
Assert.Equal("referencedValue", await referencedParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
813
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
814
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
815
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
839
Assert.NotNull(parameterResource.
WaitForValueTcs
);
840
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
841
Assert.Equal("envValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
861
Assert.NotNull(parameterResource.
WaitForValueTcs
);
862
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
863
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
883
Assert.NotNull(parameterResource.
WaitForValueTcs
);
884
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
885
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
909
Assert.NotNull(parameterResource.
WaitForValueTcs
);
910
Assert.False(parameterResource.
WaitForValueTcs
.Task.IsCompleted);
943
Assert.NotNull(param.
WaitForValueTcs
);
944
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
980
Assert.NotNull(parameterResource.
WaitForValueTcs
);
981
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1020
Assert.NotNull(parameterResource.
WaitForValueTcs
);
1021
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1279
Assert.False(parameter.
WaitForValueTcs
.Task.IsCompleted);
1822
Assert.NotNull(parameterWithGenerateDefault.
WaitForValueTcs
);
1823
Assert.True(parameterWithGenerateDefault.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1824
Assert.Equal("existingValue", await parameterWithGenerateDefault.
WaitForValueTcs
.Task.DefaultTimeout());
Pipelines\DistributedApplicationPipelineTests.cs (2)
2101
Assert.NotNull(paramResource.
WaitForValueTcs
);
2102
Assert.True(paramResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);