Hey all, I’m trying to think of a way to have a RxJava2 operator that is something like `Single.amb(...

# rx

[Keith Mayoral]

Hey all, I’m trying to think of a way to have a RxJava2 operator that is something like Single.amb(sourcesList) which behaves just like amb when any input Single source succeeds but only errors out after all input sources have failed (as opposed to amb() which errors out immediately if the first source to complete errored out)

[ephemient]

been ages since I've looked at rx (why not switch to kotlinx.coroutines?) and I haven't anything setup to test this, but but in principle this shouldn't be too difficult

rxjava2-single-amb.kt

[devKshitijJain]

Can you not use ErrorResumeNext? I guess it continue with some default item if any of source throw error.

[ephemient]

even if you do something like Single.amb(sourcesList).retry() or equivalent with onErrorResumeNext, one source failing cancels everything else that's currently in-flight, forcing them to be re-subscribed on retry/resume