1 write to _itemCountingFunc
System.Threading.Tasks.Dataflow (1)
Internal\SourceCore.cs (1)
116_itemCountingFunc = itemCountingFunc;
8 references to _itemCountingFunc
System.Threading.Tasks.Dataflow (8)
Internal\SourceCore.cs (8)
209int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, consumedMessageValue, null) : 1; 320int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, item!, null) : 1; 367int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, default(TOutput)!, items) : countReceived; 652int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, message!, null) : 1;