1 write to _currentMessage
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
739_currentMessage = message = _messages.Dequeue();
5 references to _currentMessage
System.Threading.Tasks.Dataflow (5)
Blocks\BroadcastBlock.cs (5)
573message = _currentMessage; 677currentMessage = _currentMessage; 1063valueToClone = _currentMessage; 1119messageToReoffer = _currentMessage; 1206public TOutput Value { get { return _source._currentMessage!; } }