1 write to _target1
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
79targets[0] = _target1 = new JoinBlockTarget<T1>(_sharedResources);
6 references to _target1
System.Threading.Tasks.Dataflow (6)
Blocks\JoinBlock.cs (6)
71_source.AddMessage(Tuple.Create(_target1!.GetOneMessage(), _target2!.GetOneMessage())); 84new[] { _target1.CompletionTaskInternal, _target2.CompletionTaskInternal }, 133Debug.Assert(_target1 != null, "_target1 not initialized"); 136_target1.CompleteCore(exception: null, dropPendingMessages: false, releaseReservedMessages: false); 157public ITargetBlock<T1> Target1 { get { return _target1; } } 230public ITargetBlock<T1> Target1 { get { return _joinBlock._target1; } }