3 instantiations of TargetRegistry
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (1)
563_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
Blocks\WriteOnceBlock.cs (1)
77_targetRegistry = new TargetRegistry<T>(this);
Internal\SourceCore.cs (1)
120_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
30 references to TargetRegistry
System.Threading.Tasks.Dataflow (30)
Blocks\BatchBlock.cs (1)
234public TargetRegistry<T[]> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\BatchedJoinBlock.cs (2)
260public TargetRegistry<Tuple<IList<T1>, IList<T2>>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 520public TargetRegistry<Tuple<IList<T1>, IList<T2>, IList<T3>>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\BroadcastBlock.cs (6)
489public TargetRegistry<T> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 500private readonly TargetRegistry<TOutput> _targetRegistry; 765TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 772TargetRegistry<TOutput>.LinkedTargetInfo? next = cur.Next; 962TargetRegistry<TOutput>.LinkedTargetInfo? linkedTargets; 1230public TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }
Blocks\BufferBlock.cs (1)
477public TargetRegistry<T> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\JoinBlock.cs (2)
241public TargetRegistry<Tuple<T1, T2>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 473public TargetRegistry<Tuple<T1, T2, T3>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\TransformBlock.cs (1)
451public TargetRegistry<TOutput> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\TransformManyBlock.cs (1)
657public TargetRegistry<TOutput> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\WriteOnceBlock.cs (5)
28private readonly TargetRegistry<T> _targetRegistry; 176TargetRegistry<T>.LinkedTargetInfo? linkedTargets = _targetRegistry.ClearEntryPoints(); 463TargetRegistry<T>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 466TargetRegistry<T>.LinkedTargetInfo? next = cur.Next; 551public TargetRegistry<T> LinkedTargets { get { return _writeOnceBlock._targetRegistry; } }
Internal\Common.cs (2)
405internal static IDisposable CreateUnlinker<TOutput>(object outgoingLock, TargetRegistry<TOutput> targetRegistry, ITargetBlock<TOutput> targetBlock) 601internal static readonly Action<object, TargetRegistry<T>, ITargetBlock<T>> CreateUnlinkerShimAction =
Internal\SourceCore.cs (5)
38private readonly TargetRegistry<TOutput> _targetRegistry; 595TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 598TargetRegistry<TOutput>.LinkedTargetInfo? next = cur.Next; 936TargetRegistry<TOutput>.LinkedTargetInfo? linkedTargets; 1020internal TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }
Internal\TargetRegistry.cs (4)
24[DebuggerTypeProxy(typeof(TargetRegistry<>.DebugView))] 299[DebuggerTypeProxy(typeof(TargetRegistry<>.NopLinkPropagator.DebugView))] 392private readonly TargetRegistry<T> _registry; 396public DebugView(TargetRegistry<T> registry)