1 write to _targetRegistry
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
563_targetRegistry = new TargetRegistry<TOutput>(_owningSource);
13 references to _targetRegistry
System.Threading.Tasks.Dataflow (13)
Blocks\BroadcastBlock.cs (13)
514private object ValueLock { get { return _targetRegistry; } } 703_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 709_targetRegistry.Remove(target); 734if (_targetRegistry.FirstTargetNode == null) 765TargetRegistry<TOutput>.LinkedTargetInfo? cur = _targetRegistry.FirstTargetNode; 806_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 812_targetRegistry.Remove(target); 970linkedTargets = _targetRegistry.ClearEntryPoints(); 1000_targetRegistry.PropagateCompletion(linkedTargets); 1037_targetRegistry.Add(ref target, linkOptions); 1039return Common.CreateUnlinker(OutgoingLock, _targetRegistry, target); 1069_targetRegistry.Remove(target, onlyIfReachedMaxMessages: true); 1230public TargetRegistry<TOutput> LinkedTargets { get { return _source._targetRegistry; } }