1 write to _itemsRemovedAction
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
554
_itemsRemovedAction
= itemsRemovedAction;
1 reference to _itemsRemovedAction
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
756
_itemsRemovedAction
?.Invoke(numDequeuedMessages);