lib/eventstore.js
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);
  }
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);
  }
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 ) ; }
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
stream events by revision