Base:
method
CompleteCore
System.Threading.Tasks.Dataflow.Internal.JoinBlockTargetBase.CompleteCore(System.Exception, System.Boolean, System.Boolean)
6 references to CompleteCore
System.Threading.Tasks.Dataflow (6)
Blocks\JoinBlock.cs (6)
136_target1.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 137_target2.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 356_target1.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 357_target2.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 358_target3.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 929CompleteCore(exception, dropPendingMessages: true, releaseReservedMessages: false);