1 write to _target1
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
92
_target1
= new BatchedJoinBlockTarget<T1>(_sharedResources);
7 references to _target1
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()));
120
public ITargetBlock<T1> Target1 { get { return
_target1
; } }
149
Debug.Assert(
_target1
!= null, "_target1 not initialized");
152
_target1
.Complete();
201
_target1
.Complete();
245
public ITargetBlock<T1> Target1 { get { return _batchedJoinBlock.
_target1
; } }