RxSwift(Rx全般)でストリームを分割したい

Question

let buttonTap: Observable<Void> = ....
let maybeError: Observable<Data> = ....

buttonTap.flatMap {
  maybeError.map { Result($0) }
}
  .subscribe(
      onNext: { _ in
         print("Success!!!")
      },
      onError: {
         print($0)
      }
  )

でストリームを合成後にmaybeErrorでエラーが発生した場合、その後ボタンのタップのストリームも終了してしまいますが、maybeErrorで発生した場合でもボタンタップのストリームは終了しないようにする書き方はあるか知りたいです。

buttonTap.subscribe(onNext: {
  maybeError.subscribe()
})

こんな書き方はおかしいので行いたいくないため。

何かいい方法があればご教授ください。
よろしくお願いします。

Answer 1

maybeErrorでonErrorが発生した場合でもbuttonTapが終了させない方法として2つ考えられます。

• onError を捕捉して復旧させる

buttonTap.flatMap {
  maybeError.map { Result($0) }.catchErrorJustReturn(Data())
}
  

errorによって復旧させたい場合はcatchErrorも使えます。

Resultパターン

enum Result<T> {
  case Success(T)
  case Error(Error)
}

maybeErrorがerrorの場合にonErrorを発生させるのではなく、onNext<Result>を発生させる