lib/eventstore.js
function (query, skip, limit) {
    if (!this.store.streamEvents) {
      throw new Error('Streaming API is not suppoted by '+(this.options.type || 'inmemory') +' db implementation.');
    }

    if (typeof query === 'number') {
      limit = skip;
      skip = query;
      query = {};      
    };

    if (typeof query === 'string') {
      query = { aggregateId: query };
    }

    return this.store.streamEvents(query, skip, limit);
  }
function (query, skip, limit) {
    if (!this.store.streamEvents) {
      throw new Error('Streaming API is not suppoted by '+(this.options.type || 'inmemory') +' db implementation.');
    }

    if (typeof query === 'number') {
      limit = skip;
      skip = query;
      query = {};      
    };

    if (typeof query === 'string') {
      query = { aggregateId: query };
    }

    return this.store.streamEvents(query, skip, limit);
  }
function ( query , skip , limit ) { if ( ! this . store . streamEvents ) { throw new Error ( 'Streaming API is not suppoted by ' + ( this . options . type || 'inmemory' ) + ' db implementation.' ) ; } if ( typeof query === 'number' ) { limit = skip ; skip = query ; query = { } ; } ; if ( typeof query === 'string' ) { query = { aggregateId : query } ; } return this . store . streamEvents ( query , skip , limit ) ; }
streaming api 
streams the events
@param {Object || String} query    the query object [optional]
@param {Number}           skip     how many events should be skipped? [optional]
@param {Number}           limit    how many events do you want in the result? [optional]
@returns {Stream} a stream with the events
streaming api streams the events