Hi all, I'm playing with Flow and error handling. ...

# coroutines

[davide]

Hi all, I'm playing with Flow and error handling. I'm doing somethink like:

(1..5).asFlow().onEach{ //throw error }.retryWhen { c, a -> ... }

But the flow restarts from the beginning. What is the best way to skip the emitted element that cause the error and restart from the next one?

[streetsofboston]

Flows, like Observable/Flowables in Rx, terminate/complete when an error occurs. You cannot resume the upstream Flow/Observable.

At best you can return a non-error value, but the Flow/Observable still terminates, or you can restart the upstream Flow/Observable entirely (it basically will re-collect/re-subscribe).

[davide]

ok, so the only way may we using catch method with emitAll on a new flux that starts from the next element

[davide]

(thanks for the answer)

[streetsofboston]

Yup, or add a try {.... } catch { ....} inside your .onEach

[davide]

yes, more simple 🙂