3 writes to _lazyCompletionTaskSource
System.Threading.Tasks.Dataflow (3)
Blocks\WriteOnceBlock.cs (3)
80_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 190if (Interlocked.CompareExchange(ref _lazyCompletionTaskSource, Common.CompletedVoidResultTaskCompletionSource, null) != null) 490Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
7 references to _lazyCompletionTaskSource
System.Threading.Tasks.Dataflow (7)
Blocks\WriteOnceBlock.cs (7)
89_lazyCompletionTaskSource.TrySetCanceled(dataflowBlockOptions.CancellationToken); 95dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, static (state, _) => ((WriteOnceBlock<T>)state!).Complete(), this); 170Debug.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."); 192_lazyCompletionTaskSource.TrySetResult(default(VoidResult)); 488if (_lazyCompletionTaskSource == null) 493return _lazyCompletionTaskSource;