1 write to _target2
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
83targets[1] = _target2 = new JoinBlockTarget<T2>(_sharedResources);
6 references to _target2
System.Threading.Tasks.Dataflow (6)
Blocks\JoinBlock.cs (6)
74_source.AddMessage(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage())); 87new[] { _target1.CompletionTaskInternal, _target2.CompletionTaskInternal }, 137Debug.Assert(_target2 != null, "_target2 not initialized"); 140_target2.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 166public ITargetBlock<T2> Target2 { get { return _target2; } } 238public ITargetBlock<T2> Target2 { get { return _joinBlock._target2; } }