20 implementations of Complete
System.Threading.Tasks.Dataflow (20)
Base\DataflowBlock.cs (7)
180void IDataflowBlock.Complete() { _target.Complete(); } 714void IDataflowBlock.Complete() { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 1348void IDataflowBlock.Complete() 1471void IDataflowBlock.Complete() => TrySetResult(false); 1534public void Complete() 2126void IDataflowBlock.Complete() 2627void IDataflowBlock.Complete() { } // No-op
Blocks\ActionBlock.cs (1)
218public void Complete()
Blocks\BatchBlock.cs (1)
99public void Complete() { _target.Complete(exception: null, dropPendingMessages: false, releaseReservedMessages: false); }
Blocks\BatchedJoinBlock.cs (3)
147public void Complete() 399public void Complete() 596public void Complete()
Blocks\BroadcastBlock.cs (1)
106public void Complete()
Blocks\BufferBlock.cs (1)
144public void Complete() { CompleteCore(exception: null, storeExceptionEvenIfAlreadyCompleting: false); }
Blocks\JoinBlock.cs (2)
131public void Complete() 350public void Complete()
Blocks\TransformBlock.cs (1)
330public 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)
214public void Complete()
Internal\TargetRegistry.cs (1)
348void IDataflowBlock.Complete() { _target.Complete(); }
7 references to Complete
System.Threading.Tasks.Dataflow (7)
Base\DataflowBlock.cs (5)
180void IDataflowBlock.Complete() { _target.Complete(); } 1354void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 1536_target.Complete(); 2132void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 2555_target.Complete();
Internal\Common.cs (1)
557else target.Complete();
Internal\TargetRegistry.cs (1)
348void IDataflowBlock.Complete() { _target.Complete(); }