1 write to _target1
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
340_target1 = new BatchedJoinBlockTarget<T1>(_sharedResources);
7 references to _target1
System.Threading.Tasks.Dataflow (7)
Blocks\BatchedJoinBlock.cs (7)
323if (_target1!.Count > 0 || _target2!.Count > 0 || _target3!.Count > 0) 325_source.AddMessage(Tuple.Create(_target1.GetAndEmptyMessages(), _target2!.GetAndEmptyMessages(), _target3!.GetAndEmptyMessages())); 369public ITargetBlock<T1> Target1 { get { return _target1; } } 401Debug.Assert(_target1 != null, "_target1 not initialized"); 405_target1.Complete(); 452_target1.Complete(); 497public ITargetBlock<T1> Target1 { get { return _batchedJoinBlock._target1; } }