Absorb the error and then try to restart the Observable which has failed using the retry() operator without delay

If an error occurs, the retry() operator enables the developers to retry the Observable for emission. The operator responds to the onError signal from the Observable, but this time instead of sending onError to the observer it will now resubscribe to the source Observable. It gives a new opportunity to the source Observable so that it will be able to complete the emission of the items. The operator retry() sends the onNext signal to the observer, which may lead to a duplicate item emission.

The retry() operator has the following four flavors which trigger resubscription to the source Observable immediately once it has failed: ...

Get Reactive Programming With Java 9 now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.