1 write to _target3
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
299targets[2] = _target3 = new JoinBlockTarget<T3>(_sharedResources);
6 references to _target3
System.Threading.Tasks.Dataflow (6)
Blocks\JoinBlock.cs (6)
290() => _source.AddMessage(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage(), _target3!.GetOneMessage())), 303new[] { _target1.CompletionTaskInternal, _target2.CompletionTaskInternal, _target3.CompletionTaskInternal }, 354Debug.Assert(_target3 != null, "_target3 not initialized"); 358_target3.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 384public ITargetBlock<T3> Target3 { get { return _target3; } } 458public ITargetBlock<T3> Target3 { get { return _joinBlock._target3; } }