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

    if (!commitStamp) {
      var err = new Error('Please pass in a date object!');
      debug(err);
      throw err;
    }

    var self = this;
    commitStamp = new Date(commitStamp);

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

    if (!commitStamp) {
      var err = new Error('Please pass in a date object!');
      debug(err);
      throw err;
    }

    var self = this;
    commitStamp = new Date(commitStamp);

    return this.store.streamEventsSince(commitStamp, skip, limit);
  }
function ( commitStamp , skip , limit ) { if ( ! this . store . streamEvents ) { throw new Error ( 'Streaming API is not suppoted by ' + ( this . options . type || 'inmemory' ) + ' db implementation.' ) ; } if ( ! commitStamp ) { var err = new Error ( 'Please pass in a date object!' ) ; debug ( err ) ; throw err ; } var self = this ; commitStamp = new Date ( commitStamp ) ; return this . store . streamEventsSince ( commitStamp , skip , limit ) ; }
streams all the events since passed commitStamp
@param {Date}     commitStamp the date object
@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
streams all the events since passed commitStamp