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); 139public 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; } } 348_source.Completion.ContinueWith(static (completed, state) => 357dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this); 396public Task Completion { get { return _source.Completion; } }
Blocks\BufferBlock.cs (3)
70_source.Completion.ContinueWith(static (completed, state) => 79dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this); 195public Task Completion { get { return _source.Completion; } }
Blocks\JoinBlock.cs (6)
92_source.Completion.ContinueWith(static (completed, state) => 101dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2>)state!)._sharedResources.CompleteEachTarget(), this); 128public Task Completion { get { return _source.Completion; } } 311_source.Completion.ContinueWith(static (completed, state) => 320dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this); 347public Task Completion { get { return _source.Completion; } }
Blocks\TransformBlock.cs (2)
151_source.Completion.ContinueWith(static (completed, state) => 356public Task Completion { get { return _source.Completion; } }
Blocks\TransformManyBlock.cs (2)
150source.Completion.ContinueWith(static (completed, state) => 565public Task Completion { get { return _source.Completion; } }
Internal\SourceCore.cs (7)
457Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 469Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 484Debug.Assert(!Completion.IsCompleted || Completion.IsFaulted, "The block must either not be completed or be faulted if we're still storing exceptions."); 1011internal bool IsCompleted { get { return _source.Completion.IsCompleted; } }