1 write to Target
System.Threading.Tasks.Dataflow (1)
Internal\TargetRegistry.cs (1)
40Target = target;
5 references to Target
System.Threading.Tasks.Dataflow (5)
Blocks\BroadcastBlock.cs (1)
773ITargetBlock<TOutput> target = cur.Target;
Blocks\WriteOnceBlock.cs (1)
467ITargetBlock<T> target = cur.Target;
Internal\SourceCore.cs (1)
599if (OfferMessageToTarget(header, message!, cur.Target, out messageWasAccepted)) break;
Internal\TargetRegistry.cs (2)
202if (node.PropagateCompletion) Common.PropagateCompletion(owningSourceCompletion, node.Target, Common.AsyncExceptionHandler); 288targets[i++] = node.Target;