How do I transform observable's error to another observable? I am trying to implement algorithm showed on scheme below: I am using a tutorial named Grokking RxJava to start my learning and found ...