Random interval observable

rx-random-interval.js

var Rx = require('rx');
var _ = require('lodash');

module.exports = function(minSeconds, maxSeconds) {
  if (minSeconds >= maxSeconds) { 
    throw new Error('min needs to be less than max');
  }

  var getDueTime = () => _.random(minSeconds, maxSeconds) * 1000;

  return new Rx.AnonymousObservable((observer) => {
    return Rx.Scheduler.timeout.scheduleRecursiveWithRelative(
      getDueTime(),
      (self) => {
        observer.onNext();
        self(getDueTime());
      }
    )
  });
}