When dealing with errors in RxJava, you should be aware that they terminate the
Observable chain of actions. Much like with your normal procedural code, once you are in the catch block, you can't go back to the code that has thrown the exception. You can execute some backup logic though and use it instead of failing the program. The
resume* operators do something similar.
onErrorReturn operator can be used in order to prevent the
onError from being called. Instead, it will emit one last item and complete. Here is an example:
Observable<String> numbers = Observable .just("1", "2", "three", "4", "5") .map(Integer::parseInt) .onErrorReturn(e -> -1); subscribePrint(numbers, ...