RxJavaでは非同期処理などで非常に便利なライブラリですが、そのエラーハンドリングもとてもスマートに行うことができます。ここではRxJavaのエラーハンドリングの詳細について説明したいと思います。 subscribeでのエラー処理 通常はsubscribe()でエラーを受け取ってハンドリングすることとなると思います。 Observable .create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { log("subscribe"); subscriber.onNext("emit 1"); subscriber.onNext("emit 2"); subscriber.onError(new Throwable());