// `map`を実行した Observable（`Rx.Observable.interval(1000)`）が

// `2`より大きな値を`next`通知したら、`error`通知をする Observable

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

  if (value > 2) {

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

  } else {

    return value;

  }

});

​

observable

  .retry(2)

  .subscribe(

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

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

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

  );

// => "next: 0"

// => "next: 1"

// => "next: 2"

// このタイミングで`observable`から`error`通知がされるため、1回目の再試行をする。

// => "next: 0"

// => "next: 1"

// => "next: 2"

// このタイミングで`observable`から`error`通知がされるため、2回目の再試行をする。

// => "next: 0"

// => "next: 1"

// => "next: 2"

// 2回再試行をしたが依然として`error`通知がされるため、Observer に`error`通知をして終了

// => "error: Error: 2より大きい!"