3 writes to _lazyCompletionTaskSource
System.Threading.Tasks.Dataflow (3)
Blocks\WriteOnceBlock.cs (3)
83_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 193if (Interlocked.CompareExchange(ref _lazyCompletionTaskSource, Common.CompletedVoidResultTaskCompletionSource, null) != null) 502Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
7 references to _lazyCompletionTaskSource
System.Threading.Tasks.Dataflow (7)
Blocks\WriteOnceBlock.cs (7)
92_lazyCompletionTaskSource.TrySetCanceled(dataflowBlockOptions.CancellationToken); 98dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, static (state, _) => ((WriteOnceBlock<T>)state!).Complete(), this); 173Debug.Assert(_lazyCompletionTaskSource == null || !_lazyCompletionTaskSource.Task.IsCompleted, "The task completion source must not be completed. This must be the only thread that ever completes the block."); 195_lazyCompletionTaskSource.TrySetResult(default(VoidResult)); 500if (_lazyCompletionTaskSource == null) 505return _lazyCompletionTaskSource;