code: function (query, revMin, revMax) {
      if (typeof query === 'string') {
        query = { aggregateId: query };
      }
  
      if (!query.aggregateId) {
        var err = new Error('An aggregateId should be passed!');
        debug(err);
        if (callback) callback(err);
        return;
      }
  
      return this.store.streamEventsByRevision(query, revMin, revMax);
    }
docs: stream events by revision
  @param {Object || String} query    the query object
  @param {Number}           revMin   revision start point [optional]
  @param {Number}           revMax   revision end point (hint: -1 = to end) [optional]
  @returns {Stream} a stream with the events