1 override of CompleteCore
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
883
internal override void
CompleteCore
(Exception? exception, bool dropPendingMessages, bool releaseReservedMessages)
3 references to CompleteCore
System.Threading.Tasks.Dataflow (3)
Blocks\JoinBlock.cs (3)
1002
public void Complete() {
CompleteCore
(exception: null, dropPendingMessages: false, releaseReservedMessages: false); }
1078
target.
CompleteCore
(exception: null, dropPendingMessages: true, releaseReservedMessages: false);
1383
_targets[0].
CompleteCore
(exception, dropPendingMessages: true, releaseReservedMessages: true);