1 write to _target3
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
345
_target3
= new BatchedJoinBlockTarget<T3>(_sharedResources);
7 references to _target3
System.Threading.Tasks.Dataflow (7)
Blocks\BatchedJoinBlock.cs (7)
326
if (_target1!.Count > 0 || _target2!.Count > 0 ||
_target3
!.Count > 0)
328
_source.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(),
_target3
!.GetAndEmptyMessages()));
378
public ITargetBlock<T3> Target3 { get { return
_target3
; } }
406
Debug.Assert(
_target3
!= null, "_target3 not initialized");
410
_target3
.Complete();
460
_target3
.Complete();
507
public ITargetBlock<T3> Target3 { get { return _batchedJoinBlock.
_target3
; } }