const promiseReject = () =>

  new Promise((resolve, reject) => reject("reject!!"));

const observable = Rx.Observable.from(promiseReject());

​

observable

  // このメソッドを実行した Observable（`observable`）が`error`を通知した際に、

  // Observable を生成する関数（`error => Rx.Observable.of(error)`）を実行し、

  // その戻り値である Observable（`Rx.Observable.of(error)`）から通知を再開する。

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

  .subscribe(

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

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

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

  );

// 今回`catch`で生成した Observable（`Rx.Observable.of(error)`）から`next`通知が

// 再開されるため、以下がコンソール出力される。

// => "next: reject!!"

// => "complete"

// 再開した Observable が通知を正常にできたので、Observer に`error`通知はされない。