1 write to _batchSize
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
313_batchSize = batchSize;
15 references to _batchSize
System.Threading.Tasks.Dataflow (15)
Blocks\BatchBlock.cs (15)
392(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.ActualMaxNumberOfGroups) 473internal int BatchSize { get { return _batchSize; } } 493_batchSize; 506bool noMoreMessages = _decliningPermanently && _messages.Count < _batchSize; 571int neededMessageCountToCompleteBatch = _batchSize - _messages.Count; 732bool fullBatch = _messages.Count >= _batchSize; 737var newBatch = new T[fullBatch ? _batchSize : _messages.Count]; 777(!allowFewerThanBatchSize && (postponed.Count < _batchSize || boundedCapacityAvailable < _batchSize))) 781poppedInitially = postponed.PopRange(postponedTemp, 0, _batchSize); 782Debug.Assert(allowFewerThanBatchSize ? poppedInitially > 0 : poppedInitially == _batchSize, 801while (reserved.Count < _batchSize) 816Debug.Assert(reserved.Count <= _batchSize, "Expected the number of reserved sources to be <= the number needed for a batch."); 849if (shouldProceedToConsume && (allowFewerThanBatchSize || reserved.Count == _batchSize)) 890itemCountNeededToCompleteBatch = _batchSize - _messages.Count;