anchor.diff:      msg.addString(_query.sql);
       msg.setLength();
       
  -    _socket.writeList(msg.buffer, 0, msg.buffer.length);
  +    _socket.add(msg.buffer);
       
       _state = _BUSY;
       _query._state = _BUSY;
  
positive.code:     _handleSocketError(new Exception("Socket closed."));
    }
    
    void _readData() {
      
      try {
        
        if (_state == _CLOSED)
          return;
        
        var data = _socket.read();
    
        if (data == null)
          return;
    
        _buffer.append(data);
  
negative.code:     msg.addString(md5);
      msg.setLength();
      
      _socket.add(msg.buffer);
    }
    
    void _readReadyForQuery(int msgType, int length) {
  