anchor.diff:          _chunks.removeAt(0);
         }
       }
  -    if (_sub.isPaused && limit > 0 && _counter < limit) {
  +    if (limitted && _sub.isPaused && _counter < limit) {
         _sub.resume();
       }
       return ret;
  
positive.code: 
    final int limit;
  
    /**
     * Create a stream buffer with optional, soft [limit] to the amount of data
     * the buffer will hold before pausing the underlying straem. A limit of 0
  
negative.code:     _sub = stream.listen((items) {
        _chunks.add(items);
        _counter += items.length;
        if (limitted && _counter >= limit) {
          _sub.pause();
        }
  
  