5 references to GetAndEmptyMessages
System.Threading.Tasks.Dataflow (5)
Blocks\BatchedJoinBlock.cs (5)
77
_source.AddMessage(Tuple.Create(_target1.
GetAndEmptyMessages
(), _target2!.
GetAndEmptyMessages
()));
328
_source.AddMessage(Tuple.Create(_target1.
GetAndEmptyMessages
(), _target2!.
GetAndEmptyMessages
(), _target3!.
GetAndEmptyMessages
()));