anchor.diff:          if (_contentLength == _currentPacket.contentLength) {
             _currentPacket.content = new String.fromCharCodes(bodyBuffer);
             _readingHeader = true;
  +
  +          /// Sink on the packet.
             this._controller.sink.add(_currentPacket);
   
  +          /// Clear the state.
  +          bodyBuffer = [];
             _currentPacket = new Packet();}
         }
       }
  
positive.code:   }
  
    void _onData(List<int> bytes) {
  
      List<int> headerBuffer = [];
      List<int> bodyBuffer   = [];
  
      for (int offset = 0; offset < bytes.length; offset++) {
        int lastChar = _currentChar;
  
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;
  