1 write to _target3
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
342
_target3
= new BatchedJoinBlockTarget<T3>(_sharedResources);
7 references to _target3
System.Threading.Tasks.Dataflow (7)
Blocks\BatchedJoinBlock.cs (7)
323
if (_target1!.Count > 0 || _target2!.Count > 0 ||
_target3
!.Count > 0)
325
_source.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(),
_target3
!.GetAndEmptyMessages()));
375
public ITargetBlock<T3> Target3 { get { return
_target3
; } }
403
Debug.Assert(
_target3
!= null, "_target3 not initialized");
407
_target3
.Complete();
454
_target3
.Complete();
501
public ITargetBlock<T3> Target3 { get { return _batchedJoinBlock.
_target3
; } }