30 writes to WaitForValueTcs
Aspire.Hosting (3)
Orchestrator\ParameterProcessor.cs (3)
58parameterResource.WaitForValueTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 480parameterResource.WaitForValueTcs = tcs; 504parameterResource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (27)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (15)
396passwordParameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 443topLevelParameter.Resource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 445referencedParameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 491secretA.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 495secretB.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 573secretA.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 577secretB.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 648secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 685secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 719secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 753secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 815secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 876coldSecret.Resource.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1026secret.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1078secret.WaitForValueTcs = waitForValueTcs;
Orchestrator\ParameterProcessorTests.cs (12)
195param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 388parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 440param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 484secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 517param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 556param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1096parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1113parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1223secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1409connectionStringParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1450regularParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1494customParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
80 references to WaitForValueTcs
Aspire.Hosting (9)
ApplicationModel\ParameterResource.cs (3)
50if (WaitForValueTcs?.Task is { IsCompleted: true } valueTask) 112if (WaitForValueTcs is not null) 115return await WaitForValueTcs.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1242if (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)
166parameterResource.WaitForValueTcs?.TrySetResult(value); 184parameterResource.WaitForValueTcs?.TrySetException(ex); 502if (parameterResource.WaitForValueTcs?.Task.IsCompleted ?? false) 507parameterResource.WaitForValueTcs?.TrySetResult(inputValue);
Aspire.Hosting.Tests (71)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (13)
397passwordParameter.WaitForValueTcs.SetResult("generated-s3cr3t"); 444topLevelParameter.Resource.WaitForValueTcs.SetResult("top-level-secret"); 446referencedParameter.WaitForValueTcs.SetResult("referenced-secret"); 492secretA.WaitForValueTcs.SetResult("value-a"); 496secretB.WaitForValueTcs.SetResult("value-b"); 574secretA.WaitForValueTcs.SetResult("value-a"); 578secretB.WaitForValueTcs.SetResult("value-b"); 649secret.WaitForValueTcs.SetResult("value-a"); 686secret.WaitForValueTcs.SetResult("value-b"); 720secret.WaitForValueTcs.SetResult("value-a"); 754secret.WaitForValueTcs.SetResult("value-b"); 801secret.WaitForValueTcs!.TrySetResult("leaked-during-mcp"); 877coldSecret.Resource.WaitForValueTcs.SetResult("value-b");
Orchestrator\ParameterProcessorTests.cs (56)
44Assert.NotNull(param.WaitForValueTcs); 45Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 47Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 70Assert.NotNull(param.WaitForValueTcs); 71Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 73Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 120Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 121Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 136Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 137Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 138Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsFaulted); 139Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.WaitForValueTcs.Task.Exception?.InnerException); 154Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 155Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 169Assert.NotNull(parameterWithError.WaitForValueTcs); 170Assert.True(parameterWithError.WaitForValueTcs.Task.IsCompleted); 171Assert.True(parameterWithError.WaitForValueTcs.Task.IsFaulted); 172Assert.IsType<InvalidOperationException>(parameterWithError.WaitForValueTcs.Task.Exception?.InnerException); 253Assert.True(param1.WaitForValueTcs!.Task.IsCompletedSuccessfully); 254Assert.True(param2.WaitForValueTcs!.Task.IsCompletedSuccessfully); 255Assert.True(secretParam.WaitForValueTcs!.Task.IsCompletedSuccessfully); 256Assert.Equal("value1", await param1.WaitForValueTcs.Task.DefaultTimeout()); 257Assert.Equal("value2", await param2.WaitForValueTcs.Task.DefaultTimeout()); 258Assert.Equal("secretValue", await secretParam.WaitForValueTcs.Task.DefaultTimeout()); 305Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 306Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 608Assert.NotNull(explicitParameterResource.WaitForValueTcs); 609Assert.NotNull(referencedParameterResource.WaitForValueTcs); 610Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 611Assert.True(referencedParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 612Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 613Assert.Equal("referencedValue", await referencedParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 652Assert.NotNull(explicitParameterResource.WaitForValueTcs); 653Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 654Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 678Assert.NotNull(parameterResource.WaitForValueTcs); 679Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 680Assert.Equal("envValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 700Assert.NotNull(parameterResource.WaitForValueTcs); 701Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 702Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 722Assert.NotNull(parameterResource.WaitForValueTcs); 723Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 724Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 748Assert.NotNull(parameterResource.WaitForValueTcs); 749Assert.False(parameterResource.WaitForValueTcs.Task.IsCompleted); 782Assert.NotNull(param.WaitForValueTcs); 783Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 819Assert.NotNull(parameterResource.WaitForValueTcs); 820Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 859Assert.NotNull(parameterResource.WaitForValueTcs); 860Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 1118Assert.False(parameter.WaitForValueTcs.Task.IsCompleted); 1387Assert.NotNull(parameterWithGenerateDefault.WaitForValueTcs); 1388Assert.True(parameterWithGenerateDefault.WaitForValueTcs.Task.IsCompletedSuccessfully); 1389Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task.DefaultTimeout());
Pipelines\DistributedApplicationPipelineTests.cs (2)
2073Assert.NotNull(paramResource.WaitForValueTcs); 2074Assert.True(paramResource.WaitForValueTcs.Task.IsCompletedSuccessfully);