3 instantiations of TargetRegistry
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (1)
557_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
Blocks\WriteOnceBlock.cs (1)
74_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)
231public TargetRegistry<T[]> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\BatchedJoinBlock.cs (2)
257public TargetRegistry<Tuple<IList<T1>, IList<T2>>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 514public TargetRegistry<Tuple<IList<T1>, IList<T2>, IList<T3>>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\BroadcastBlock.cs (6)
483public TargetRegistry<T> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 494private readonly TargetRegistry<TOutput> _targetRegistry; 759TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 766TargetRegistry<TOutput>.LinkedTargetInfo? next = cur.Next; 956TargetRegistry<TOutput>.LinkedTargetInfo? linkedTargets; 1218public TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }
Blocks\BufferBlock.cs (1)
471public TargetRegistry<T> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\JoinBlock.cs (2)
235public TargetRegistry<Tuple<T1, T2>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } } 461public TargetRegistry<Tuple<T1, T2, T3>> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\TransformBlock.cs (1)
445public TargetRegistry<TOutput> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\TransformManyBlock.cs (1)
654public TargetRegistry<TOutput> LinkedTargets { get { return _sourceDebuggingInformation.LinkedTargets; } }
Blocks\WriteOnceBlock.cs (5)
28private readonly TargetRegistry<T> _targetRegistry; 173TargetRegistry<T>.LinkedTargetInfo? linkedTargets = _targetRegistry.ClearEntryPoints(); 451TargetRegistry<T>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 454TargetRegistry<T>.LinkedTargetInfo? next = cur.Next; 539public 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; 589TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 592TargetRegistry<TOutput>.LinkedTargetInfo? next = cur.Next; 930TargetRegistry<TOutput>.LinkedTargetInfo? linkedTargets; 1014internal 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)