How to handle errors in an Observable chain conditionally?

Question

I am using onErrorReturn to emit a particular item rather than invoking onError if the observable encounters an error:

Observable<String> observable = getObservableSource(); observable.onErrorReturn(error -> "All Good!") .subscribeOn(Schedulers.io()) .observeOn(Schedulers.trampoline()) .subscribe(item -> onNextAction(), error -> onErrorAction() );

This works fine, but I want to consume the error in onErrorReturn only if certain conditions are met. Just like rethrowing an exception from inside a catch block.

Something like:

onErrorReturn(error -> { if (condition) { return "All Good!"; } else { // Don't consume error. What to do here? throw error; // This gives error [Unhandled Exception: java.lang.Throwable] } });

Is there a way to propagate the error down the observable chain from inside onErrorReturn as if onErrorReturn was never there?

Did you manage to solve this ?

Grodriguez
– Grodriguez

2018-08-28 10:39:17 +00:00
Commented Aug 28, 2018 at 10:39 — Grodriguez
– Grodriguez, Commented Aug 28, 2018 at 10:39

Abhishek Jain · Accepted Answer · 2018-12-14 05:36:41Z

Using onErrorResumeNext I guess you can achieve what you want

observable.onErrorResumeNext(error -> { if(errorOk) return Observable.just(ok) else return Observable.error(error) }) .subscribeOn(Schedulers.io()) .observeOn(Schedulers.trampoline()) .subscribe(item -> onNextAction(), error -> onErrorAction() );

Massita · Accepted Answer · 2018-04-09 19:35:08Z

You can create an method that will receive this error normally, something like

private void onError(Throwable error) { // do whatever you want with your error } ... .onErrorReturn( error -> onError(error) )

Collectives™ on Stack Overflow

How to handle errors in an Observable chain conditionally?

2 Answers 2

Comments

Comments

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Related