1 write to _target1
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
343_target1 = new BatchedJoinBlockTarget<T1>(_sharedResources);
7 references to _target1
System.Threading.Tasks.Dataflow (7)
Blocks\BatchedJoinBlock.cs (7)
326if (_target1!.Count > 0 || _target2!.Count > 0 || _target3!.Count > 0) 328_source.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(), _target3!.GetAndEmptyMessages())); 372public ITargetBlock<T1> Target1 { get { return _target1; } } 404Debug.Assert(_target1 != null, "_target1 not initialized"); 408_target1.Complete(); 458_target1.Complete(); 503public ITargetBlock<T1> Target1 { get { return _batchedJoinBlock._target1; } }