30 writes to WaitForValueTcs
Aspire.Hosting (3)
Orchestrator\ParameterProcessor.cs (3)
55
parameterResource.
WaitForValueTcs
= new(TaskCreationOptions.RunContinuationsAsynchronously);
477
parameterResource.
WaitForValueTcs
= tcs;
501
parameterResource.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (27)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (15)
396
passwordParameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
443
topLevelParameter.Resource.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
445
referencedParameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
491
secretA.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
495
secretB.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
573
secretA.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
577
secretB.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
648
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
685
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
719
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
753
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
815
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
876
coldSecret.Resource.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1026
secret.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1078
secret.
WaitForValueTcs
= waitForValueTcs;
Orchestrator\ParameterProcessorTests.cs (12)
193
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
386
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
438
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
482
secretParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
515
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
554
param.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1094
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1111
parameter.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1221
secretParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1407
connectionStringParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1448
regularParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
1492
customParam.
WaitForValueTcs
= new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
80 references to WaitForValueTcs
Aspire.Hosting (9)
ApplicationModel\ParameterResource.cs (3)
50
if (
WaitForValueTcs
?.Task is { IsCompleted: true } valueTask)
112
if (
WaitForValueTcs
is not null)
115
return await
WaitForValueTcs
.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1264
if (parameter.
WaitForValueTcs
is { } waitForValueTcs)
Backchannel\SecretRedactionHistory.cs (1)
32
/// path swaps a completed <see cref="ParameterResource.
WaitForValueTcs
"/> for a new one
Orchestrator\ParameterProcessor.cs (4)
163
parameterResource.
WaitForValueTcs
?.TrySetResult(value);
181
parameterResource.
WaitForValueTcs
?.TrySetException(ex);
499
if (parameterResource.
WaitForValueTcs
?.Task.IsCompleted ?? false)
504
parameterResource.
WaitForValueTcs
?.TrySetResult(inputValue);
Aspire.Hosting.Tests (71)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (13)
397
passwordParameter.
WaitForValueTcs
.SetResult("generated-s3cr3t");
444
topLevelParameter.Resource.
WaitForValueTcs
.SetResult("top-level-secret");
446
referencedParameter.
WaitForValueTcs
.SetResult("referenced-secret");
492
secretA.
WaitForValueTcs
.SetResult("value-a");
496
secretB.
WaitForValueTcs
.SetResult("value-b");
574
secretA.
WaitForValueTcs
.SetResult("value-a");
578
secretB.
WaitForValueTcs
.SetResult("value-b");
649
secret.
WaitForValueTcs
.SetResult("value-a");
686
secret.
WaitForValueTcs
.SetResult("value-b");
720
secret.
WaitForValueTcs
.SetResult("value-a");
754
secret.
WaitForValueTcs
.SetResult("value-b");
801
secret.
WaitForValueTcs
!.TrySetResult("leaked-during-mcp");
877
coldSecret.Resource.
WaitForValueTcs
.SetResult("value-b");
Orchestrator\ParameterProcessorTests.cs (56)
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());
303
Assert.NotNull(parameterWithMissingValue.
WaitForValueTcs
);
304
Assert.False(parameterWithMissingValue.
WaitForValueTcs
.Task.IsCompleted);
606
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
607
Assert.NotNull(referencedParameterResource.
WaitForValueTcs
);
608
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
609
Assert.True(referencedParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
610
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
611
Assert.Equal("referencedValue", await referencedParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
650
Assert.NotNull(explicitParameterResource.
WaitForValueTcs
);
651
Assert.True(explicitParameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
652
Assert.Equal("explicitValue", await explicitParameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
676
Assert.NotNull(parameterResource.
WaitForValueTcs
);
677
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
678
Assert.Equal("envValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
698
Assert.NotNull(parameterResource.
WaitForValueTcs
);
699
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
700
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
720
Assert.NotNull(parameterResource.
WaitForValueTcs
);
721
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
722
Assert.Equal("testValue", await parameterResource.
WaitForValueTcs
.Task.DefaultTimeout());
746
Assert.NotNull(parameterResource.
WaitForValueTcs
);
747
Assert.False(parameterResource.
WaitForValueTcs
.Task.IsCompleted);
780
Assert.NotNull(param.
WaitForValueTcs
);
781
Assert.True(param.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
817
Assert.NotNull(parameterResource.
WaitForValueTcs
);
818
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
857
Assert.NotNull(parameterResource.
WaitForValueTcs
);
858
Assert.True(parameterResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1116
Assert.False(parameter.
WaitForValueTcs
.Task.IsCompleted);
1385
Assert.NotNull(parameterWithGenerateDefault.
WaitForValueTcs
);
1386
Assert.True(parameterWithGenerateDefault.
WaitForValueTcs
.Task.IsCompletedSuccessfully);
1387
Assert.Equal("existingValue", await parameterWithGenerateDefault.
WaitForValueTcs
.Task.DefaultTimeout());
Pipelines\DistributedApplicationPipelineTests.cs (2)
2071
Assert.NotNull(paramResource.
WaitForValueTcs
);
2072
Assert.True(paramResource.
WaitForValueTcs
.Task.IsCompletedSuccessfully);