const observable = Rx.Observable.interval(1000).map(value => {

  if (value > 2) {

    throw new Error('2より大きい!');

  } else {

    return value;

  }

});

​

observable

  .retry(2)

  .catch(error => Rx.Observable.of('catch!!'))

  .subscribe(

    x => console.log(`next: ${x}`),

    error => console.error(`error: ${error}`),

    () => console.log('complete')

  );