結論 RxKotlinの場合はdoOnErro()オペレータを使って、ストリームにErrorが流れた時をトリガーに処理を実行することができます。下記の例では、Firebase上でユーザを作成する際に、Errorハンドリングとして、AuthのcurrentUserを削除するようにしています。 return authRepository.signUp(email, password) .flatMap { userRepository.create(it) } .flatMap { saveToRealm(it) } .doOnError { removeCurrentUser() } react…