anchor.diff:    }
     
     void _handleSocketError(error) {    
  -    _socket.close();
  +    _socket.destroy();
   
       if (_state == _CLOSED)
         return;
  
positive.code:     if (msgType == _MSG_ERROR_RESPONSE) {
        if (!_hasConnected) {
            _state = _CLOSED;
            _socket.close();
            _connected.completeError(notice);                     
        } else if (_query != null) {
          _query.streamError(notice);
  
negative.code:   void close() {
      _state = _CLOSED;
      
      try {
        var msg = new _MessageBuffer();
        msg.addByte(_MSG_TERMINATE);
        msg.addInt32(0);
        msg.setLength();
        
        _socket.add(msg.buffer);
      } catch (e) {
        //FIXME Add a connection level error handler.
        print('Postgresql connection closed without sending terminate message. Error: $e');
      }
  
      _socket.destroy();
    }
  }
  