retryWhen.js

'use strict';

const Observable = require('./observable');

Observable.addToObject({
  just: require('./observable/just')
});

Observable.addToPrototype({
  delay: require('./observable/delay'),
  repeatWhen: require('./observable/repeatWhen'),
  scan: require('./observable/scan'),
  takeWhile: require('./observable/takewhile')
});

const source = Observable.just(42).repeatWhen((xs) =>
  xs.scan(acc => acc + 1, 0)
    .delay(5000)
    .takeWhile(x => x < 2)
);

source.subscribe(
  x => console.log(`Next ${x}`),
  e => console.log(`Error ${e}`),
  () => console.log(`Completed`)
);

// => Next 42
// => Next 42
// => Completed