code: 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);
    }
docs: 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