code: function _abort(err) {
    this._queue = null;
    this._commands = null;
    // listen for the event so we can clean reference
    function onError() {
      this._client = null;
    }
    this._client.once('error', onError.bind(this));
    this._client.emit('error', err);
  }
docs: Abort with an error.