anchor.diff:      msg.addString(md5);
       msg.setLength();
       
  -    _socket.writeList(msg.buffer, 0, msg.buffer.length);
  +    _socket.add(msg.buffer);
     }
     
     void _readReadyForQuery(int msgType, int length) {
  
positive.code:   int _msgLength;
  
    static Future<_Connection> _connect(_Settings settings) {
      var socket = new Socket(settings._host, settings._port);
      var conn = new _Connection(socket, settings);
      
      socket
      ..onConnect = () {
        conn._state = _SOCKET_CONNECTED;
        conn._sendStartupMessage();
      }
      ..onData = conn._readData
      ..onError = conn._handleSocketError
      ..onClosed = conn._handleSocketClosed;
      
      return conn._connected.future;
    }
    
    
  
negative.code:     msg.addInt32(0);
      msg.setLength();
      
      _socket.add(msg.buffer);
      _socket.close();
    }
  }
  