anchor.diff:      _sub = stream.listen((items) {
         _chunks.add(items);
         _counter += items.length;
  -      if (limitted && _counter >= limit) {
  +      if (limited && _counter >= limit) {
           _sub.pause();
         }
   
  
positive.code:   Future<List<T>> read(int size) {
      // If we have enough data to consume and there are no other readers, then
      // we can return immediately.
      if (limitted && size > limit) {
        throw new ArgumentError("Cannot read $size with limit $limit");
      }
  
  
negative.code: 
    final int limit;
  
    bool get limited => limit > 0;
  
    /**
     * Create a stream buffer with optional, soft [limit] to the amount of data
     * the buffer will hold before pausing the underlying stream. A limit of 0
     * means no buffer limits.
     */
    StreamBuffer({this.limit: 0});
  