1 write to _target2
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
93
_target2
= new BatchedJoinBlockTarget<T2>(_sharedResources);
7 references to _target2
System.Threading.Tasks.Dataflow (7)
Blocks\BatchedJoinBlock.cs (7)
75
if (_target1!.Count > 0 ||
_target2
!.Count > 0)
77
_source.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(),
_target2
!.GetAndEmptyMessages()));
123
public ITargetBlock<T2> Target2 { get { return
_target2
; } }
150
Debug.Assert(
_target2
!= null, "_target2 not initialized");
153
_target2
.Complete();
202
_target2
.Complete();
247
public ITargetBlock<T2> Target2 { get { return _batchedJoinBlock.
_target2
; } }