Rx.Observable.retry example

retry-example.js

function randomErrorObs() {
  return Rx.Observable.create(obs => {
    let n = 0;
    if(Math.random() < 0.5) {
      obs.next(++n);
    } else {
      console.warn('producing error');
      obs.error('bummer');
    }
  });
}

// retries 3 times, completes on the 4th failure
Rx.Observable.interval(300)
  .switchMapTo(randomErrorObs())
  .retry(3)
  .subscribe(console.log, console.error, () => console.log('completed'))