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