6 writes to _decliningPermanently
System.Threading.Tasks.Dataflow (6)
Blocks\BatchBlock.cs (6)
394_decliningPermanently = true; 464_decliningPermanently = true; 514_decliningPermanently = true; 741if (_batchesCompleted >= _dataflowBlockOptions.ActualMaxNumberOfGroups) _decliningPermanently = true; 844_decliningPermanently = true; 956_decliningPermanently = true;
13 references to _decliningPermanently
System.Threading.Tasks.Dataflow (13)
Blocks\BatchBlock.cs (13)
332if (!_decliningPermanently && !_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 358if (_decliningPermanently) 391if (!_decliningPermanently && 432if (exception != null && (!_decliningPermanently || releaseReservedMessages)) 506bool noMoreMessages = _decliningPermanently && _messages.Count < _batchSize; 585if (_decliningPermanently) 774if (_decliningPermanently || 836if (!_decliningPermanently && 843shouldProceedToConsume = !_decliningPermanently; 891if (_decliningPermanently || 948if (!_decliningPermanently && 955shouldProceedToConsume = !_decliningPermanently; 1183public bool IsDecliningPermanently { get { return _target._decliningPermanently; } }