1 write to _batchesCompleted
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
740_batchesCompleted++;
7 references to _batchesCompleted
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (7)
392(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 505bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 565bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups; 741if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 837(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 949(_batchesCompleted + 1) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 1187public long NumberOfBatchesCompleted { get { return _target._batchesCompleted; } }