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)
139_target1.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 140_target2.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 365_target1.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 366_target2.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 367_target3.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 944CompleteCore(exception, dropPendingMessages: true, releaseReservedMessages: false);