if (typeof metadata[key].reject === 'function') {
      metadata[key].reject(new errors.ReqlServerError(
          'The connection was closed before the query could be completed.',
          metadata[key].query));
    }