30 writes to WaitForValueTcs
Aspire.Hosting (3)
Orchestrator\ParameterProcessor.cs (3)
55parameterResource.WaitForValueTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 477parameterResource.WaitForValueTcs = tcs; 501parameterResource.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)
193param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 386parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 438param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 482secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 515param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 554param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1094parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1111parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1221secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1407connectionStringParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1448regularParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 1492customParam.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)
1264if (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)
163parameterResource.WaitForValueTcs?.TrySetResult(value); 181parameterResource.WaitForValueTcs?.TrySetException(ex); 499if (parameterResource.WaitForValueTcs?.Task.IsCompleted ?? false) 504parameterResource.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)
42Assert.NotNull(param.WaitForValueTcs); 43Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 45Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 68Assert.NotNull(param.WaitForValueTcs); 69Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 71Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 118Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 119Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 134Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 135Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 136Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsFaulted); 137Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.WaitForValueTcs.Task.Exception?.InnerException); 152Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 153Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 167Assert.NotNull(parameterWithError.WaitForValueTcs); 168Assert.True(parameterWithError.WaitForValueTcs.Task.IsCompleted); 169Assert.True(parameterWithError.WaitForValueTcs.Task.IsFaulted); 170Assert.IsType<InvalidOperationException>(parameterWithError.WaitForValueTcs.Task.Exception?.InnerException); 251Assert.True(param1.WaitForValueTcs!.Task.IsCompletedSuccessfully); 252Assert.True(param2.WaitForValueTcs!.Task.IsCompletedSuccessfully); 253Assert.True(secretParam.WaitForValueTcs!.Task.IsCompletedSuccessfully); 254Assert.Equal("value1", await param1.WaitForValueTcs.Task.DefaultTimeout()); 255Assert.Equal("value2", await param2.WaitForValueTcs.Task.DefaultTimeout()); 256Assert.Equal("secretValue", await secretParam.WaitForValueTcs.Task.DefaultTimeout()); 303Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 304Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 606Assert.NotNull(explicitParameterResource.WaitForValueTcs); 607Assert.NotNull(referencedParameterResource.WaitForValueTcs); 608Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 609Assert.True(referencedParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 610Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 611Assert.Equal("referencedValue", await referencedParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 650Assert.NotNull(explicitParameterResource.WaitForValueTcs); 651Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 652Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 676Assert.NotNull(parameterResource.WaitForValueTcs); 677Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 678Assert.Equal("envValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 698Assert.NotNull(parameterResource.WaitForValueTcs); 699Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 700Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 720Assert.NotNull(parameterResource.WaitForValueTcs); 721Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 722Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 746Assert.NotNull(parameterResource.WaitForValueTcs); 747Assert.False(parameterResource.WaitForValueTcs.Task.IsCompleted); 780Assert.NotNull(param.WaitForValueTcs); 781Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 817Assert.NotNull(parameterResource.WaitForValueTcs); 818Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 857Assert.NotNull(parameterResource.WaitForValueTcs); 858Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 1116Assert.False(parameter.WaitForValueTcs.Task.IsCompleted); 1385Assert.NotNull(parameterWithGenerateDefault.WaitForValueTcs); 1386Assert.True(parameterWithGenerateDefault.WaitForValueTcs.Task.IsCompletedSuccessfully); 1387Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task.DefaultTimeout());
Pipelines\DistributedApplicationPipelineTests.cs (2)
2071Assert.NotNull(paramResource.WaitForValueTcs); 2072Assert.True(paramResource.WaitForValueTcs.Task.IsCompletedSuccessfully);