29 references to Completion
System.Threading.Tasks.Dataflow (29)
Blocks\BatchBlock.cs (3)
81_source.Completion.ContinueWith(static (completed, state) => 90dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchBlockTargetCore)state!).Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), _target); 142public Task Completion { get { return _source.Completion; } }
Blocks\BatchedJoinBlock.cs (6)
99_source.Completion.ContinueWith(static (completed, state) => 108dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2>)state!).CompleteEachTarget(), this); 144public Task Completion { get { return _source.Completion; } } 351_source.Completion.ContinueWith(static (completed, state) => 360dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this); 399public Task Completion { get { return _source.Completion; } }
Blocks\BufferBlock.cs (3)
73_source.Completion.ContinueWith(static (completed, state) => 82dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this); 201public Task Completion { get { return _source.Completion; } }
Blocks\JoinBlock.cs (6)
95_source.Completion.ContinueWith(static (completed, state) => 104dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2>)state!)._sharedResources.CompleteEachTarget(), this); 131public Task Completion { get { return _source.Completion; } } 320_source.Completion.ContinueWith(static (completed, state) => 329dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this); 356public Task Completion { get { return _source.Completion; } }
Blocks\TransformBlock.cs (2)
154_source.Completion.ContinueWith(static (completed, state) => 362public Task Completion { get { return _source.Completion; } }
Blocks\TransformManyBlock.cs (2)
150source.Completion.ContinueWith(static (completed, state) => 568public Task Completion { get { return _source.Completion; } }
Internal\SourceCore.cs (7)
463Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 475Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 490Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 1017internal bool IsCompleted { get { return _source.Completion.IsCompleted; } }