1 write to _batchesCompleted
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
743_batchesCompleted++;
7 references to _batchesCompleted
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (7)
395(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 508bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 568bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 744if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 840(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 952(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 1190public long NumberOfBatchesCompleted { get { return _target._batchesCompleted; } }