anchor.diff:          _handleBytes(bytes, offset);
         }
       }
  -  }
  -
  -  /// Stop listening to the input stream for further updates, and close the
  -  /// output stream.
  -  void cancel() {
  -    _inputStreamSubscription.cancel();
  -    _messageStreamController.close();
     }
   }
   
  
positive.code:     bytes[_offset++] = byte;
    }
  
    /// Reset the number of added bytes to zero.
    void reset() {
      _offset = 0;
  
negative.code: // BSD-style license that can be found in the LICENSE file.
  
  import 'dart:async';
  import 'dart:math' as math;
  import 'dart:typed_data';
  
  /// Collects messages from an input stream of bytes.
  