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