1 write to _targetRegistry
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
557_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
13 references to _targetRegistry
System.Threading.Tasks.Dataflow (13)
Blocks\BroadcastBlock.cs (13)
508private object ValueLock { get { return _targetRegistry; } } 697_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 703_targetRegistry.Remove(target); 728if (_targetRegistry.FirstTargetNode == null) 759TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 800_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 806_targetRegistry.Remove(target); 964linkedTargets = _targetRegistry.ClearEntryPoints(); 994_targetRegistry.PropagateCompletion(linkedTargets); 1025_targetRegistry.Add(ref target, linkOptions); 1027return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 1057_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 1218public TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }