cahnge onError to onErrorResumeNext

This commit is contained in:
Alexander Bubnov 2017-03-28 12:19:06 +03:00
parent 96b5ac276f
commit f8df418f46
1 changed files with 1 additions and 9 deletions

View File

@ -38,7 +38,6 @@ import rx.SingleSubscriber;
import rx.Subscriber;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
import rx.exceptions.OnErrorThrowable;
import rx.functions.Action0;
import rx.functions.Action1;
import rx.functions.Actions;
@ -264,14 +263,7 @@ public abstract class TouchinService<TLogic extends Logic> extends Service {
actualObservable = observable.observeOn(AndroidSchedulers.mainThread())
.doOnCompleted(onCompletedAction)
.doOnNext(onNextAction)
.doOnError(throwable -> {
final boolean isRxError = throwable instanceof OnErrorThrowable;
if ((!isRxError && throwable instanceof RuntimeException)
|| (isRxError && throwable.getCause() instanceof RuntimeException)) {
Lc.assertion(throwable);
}
onErrorAction.call(throwable);
});
.onErrorResumeNext(Observable.empty());
}
return isCreatedSubject.first()