Rxjavaでのネットワークエラーの処理2 - Retrofit 2

Question

Rxjava2でさまざまなネットワークエラーを処理するにはどうすればよいですか？

Rxjava 1ではIOExceptionまたはHttpExceptionが戻ってきたが、RxJava 2ではthrowableエラーの型がGaiExceptionになっています。

コードスニペット

RestAPI restAPI = RetrofitHelper.createRetrofitWithGson().create(RestAPI.class); 
Observable<BaseResponseTourPhoto> observable = restAPI.fetchData("Bearer " + getAccessToken(), "2", "" + page) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()); 

Disposable subscription = observable.subscribe(BaseResponse-> { 
    onLoadingFinish(isPageLoading, isRefreshing); 
    onLoadingSuccess(isPageLoading, BaseResponse); 
    writeToRealm(BaseResponse.getData()); 
}, error -> { 
    onLoadingFinish(isPageLoading, isRefreshing); 
    onLoadingFailed(error); 
}); 

mCompositeDisposable = new CompositeDisposable(); 
mCompositeDisposable.add(subscription); 
unsubscribeOnDestroy(mCompositeDisposable); 

参照：https://github.com/square/retrofit/issues/690 https://android.googlesource.com/platform/libcore/+/5d930ca/luni/src/main/java/android/system/GaiException.java

Answer 1

.onErrorReturn((Throwable ex) -> { 
    print(ex); //examine error here 
    return ""; //empty object of the datatype 
}) 
.subscribe((String res) -> { 
    if(res.isEmpty()) //some condition to check error 
     return; 
    doStuff(res); 
});