20 implementations of Complete
System.Threading.Tasks.Dataflow (20)
Base\DataflowBlock.cs (7)
198void IDataflowBlock.Complete() { _target.Complete(); } 738void IDataflowBlock.Complete() { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 1381void IDataflowBlock.Complete() 1504void IDataflowBlock.Complete() => TrySetResult(false); 1576public void Complete() 2207void IDataflowBlock.Complete() 2717void IDataflowBlock.Complete() { } // No-op
Blocks\ActionBlock.cs (1)
224public void Complete()
Blocks\BatchBlock.cs (1)
99public void Complete() { _target.Complete(exception: null, dropPendingMessages: false, releaseReservedMessages: false); }
Blocks\BatchedJoinBlock.cs (3)
147public void Complete() 402public void Complete() 602public void Complete()
Blocks\BroadcastBlock.cs (1)
109public void Complete()
Blocks\BufferBlock.cs (1)
147public void Complete() { CompleteCore(exception: null, storeExceptionEvenIfAlreadyCompleting: false); }
Blocks\JoinBlock.cs (2)
134public void Complete() 359public void Complete()
Blocks\TransformBlock.cs (1)
333public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); }
Blocks\TransformManyBlock.cs (1)
545public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); }
Blocks\WriteOnceBlock.cs (1)
220public void Complete()
Internal\TargetRegistry.cs (1)
348void IDataflowBlock.Complete() { _target.Complete(); }
7 references to Complete
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (5)
198void IDataflowBlock.Complete() { _target.Complete(); } 1387void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 1578_target.Complete(); 2213void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 2645_target.Complete();
Internal\Common.cs (1)
557else target.Complete();
Internal\TargetRegistry.cs (1)
348void IDataflowBlock.Complete() { _target.Complete(); }