9 writes to WaitForValueTcs
Aspire.Hosting (1)
Orchestrator\ParameterProcessor.cs (1)
42parameterResource.WaitForValueTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (8)
Orchestrator\ParameterProcessorTests.cs (8)
186param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 275parameterWithMissingValue.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 370parameter.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 419param.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 460secretParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 875connectionStringParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 914regularParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 956customParam.WaitForValueTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
62 references to WaitForValueTcs
Aspire.Hosting (5)
ApplicationModel\ParameterResource.cs (2)
87if (WaitForValueTcs is not null) 90return await WaitForValueTcs.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
Orchestrator\ParameterProcessor.cs (3)
168parameterResource.WaitForValueTcs?.TrySetResult(value); 185parameterResource.WaitForValueTcs?.TrySetException(ex); 306parameter.WaitForValueTcs?.TrySetResult(inputValue);
Aspire.Hosting.Tests (57)
Orchestrator\ParameterProcessorTests.cs (55)
39Assert.NotNull(param.WaitForValueTcs); 40Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 42Assert.Equal(param.Value, await param.WaitForValueTcs.Task); 65Assert.NotNull(param.WaitForValueTcs); 66Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 68Assert.Equal(param.Value, await param.WaitForValueTcs.Task); 115Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 116Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 131Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 132Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 133Assert.True(parameterWithMissingValue.WaitForValueTcs.Task.IsFaulted); 134Assert.IsType<MissingParameterValueException>(parameterWithMissingValue.WaitForValueTcs.Task.Exception?.InnerException); 149Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 150Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 164Assert.NotNull(parameterWithError.WaitForValueTcs); 165Assert.True(parameterWithError.WaitForValueTcs.Task.IsCompleted); 166Assert.True(parameterWithError.WaitForValueTcs.Task.IsFaulted); 167Assert.IsType<InvalidOperationException>(parameterWithError.WaitForValueTcs.Task.Exception?.InnerException); 244Assert.True(param1.WaitForValueTcs!.Task.IsCompletedSuccessfully); 245Assert.True(param2.WaitForValueTcs!.Task.IsCompletedSuccessfully); 246Assert.True(secretParam.WaitForValueTcs!.Task.IsCompletedSuccessfully); 247Assert.Equal("value1", await param1.WaitForValueTcs.Task); 248Assert.Equal("value2", await param2.WaitForValueTcs.Task); 249Assert.Equal("secretValue", await secretParam.WaitForValueTcs.Task); 292Assert.NotNull(parameterWithMissingValue.WaitForValueTcs); 293Assert.False(parameterWithMissingValue.WaitForValueTcs.Task.IsCompleted); 506Assert.NotNull(explicitParameterResource.WaitForValueTcs); 507Assert.NotNull(referencedParameterResource.WaitForValueTcs); 508Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 509Assert.True(referencedParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 510Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task); 511Assert.Equal("referencedValue", await referencedParameterResource.WaitForValueTcs.Task); 550Assert.NotNull(explicitParameterResource.WaitForValueTcs); 551Assert.True(explicitParameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 552Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task); 576Assert.NotNull(parameterResource.WaitForValueTcs); 577Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 578Assert.Equal("envValue", await parameterResource.WaitForValueTcs.Task); 598Assert.NotNull(parameterResource.WaitForValueTcs); 599Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 600Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task); 620Assert.NotNull(parameterResource.WaitForValueTcs); 621Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 622Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task); 646Assert.NotNull(parameterResource.WaitForValueTcs); 647Assert.False(parameterResource.WaitForValueTcs.Task.IsCompleted); 680Assert.NotNull(param.WaitForValueTcs); 681Assert.True(param.WaitForValueTcs.Task.IsCompletedSuccessfully); 717Assert.NotNull(parameterResource.WaitForValueTcs); 718Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 757Assert.NotNull(parameterResource.WaitForValueTcs); 758Assert.True(parameterResource.WaitForValueTcs.Task.IsCompletedSuccessfully); 855Assert.NotNull(parameterWithGenerateDefault.WaitForValueTcs); 856Assert.True(parameterWithGenerateDefault.WaitForValueTcs.Task.IsCompletedSuccessfully); 857Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task);
Pipelines\DistributedApplicationPipelineTests.cs (2)
2094Assert.NotNull(paramResource.WaitForValueTcs); 2095Assert.True(paramResource.WaitForValueTcs.Task.IsCompletedSuccessfully);