anchor.diff:    }
   
     void _onData(List<int> bytes) {
  -
  -    List<int> headerBuffer = [];
  -    List<int> bodyBuffer   = [];
   
       for (int offset = 0; offset < bytes.length; offset++) {
         int lastChar = _currentChar;
  
positive.code:         if (_contentLength == _currentPacket.contentLength) {
            _currentPacket.content = new String.fromCharCodes(bodyBuffer);
            _readingHeader = true;
            this._controller.sink.add(_currentPacket);
  
            _currentPacket = new Packet();}
        }
      }
  
negative.code: class PacketTransformer implements StreamTransformer<List<int>, Packet> {
    final StreamController<Packet> _controller = new StreamController<Packet>();
    Packet _currentPacket = new Packet();
    List<int> headerBuffer = [];
    List<int> bodyBuffer   = [];
    bool _readingHeader = true;
    int _contentLength = 0;
    int _currentChar;
  