То что нужно! Спасибо 👍

все мы через это проходим

Switchmap?

concatMap

Это не те дроиды)

Понял

Что за дроиды?

Привет! Ребята, подскажите, как проверять и нормально обрабатывать пустые эмиты (пустые выборки из ROOM)?  Уже какие только костыли не делал, но в проклатый map не заходит, цепочка рвётся

Изначально убрать пустые?

room умеет бросать ексепшены на пустые выборки, но это тоже неверно ИМХО

Привет! Как в rxjava пробросить свою ошибку заместо пришедшей, только сделать это ещё до подписки, до subscribe?

Пытаюсь сделать throw в doOnError, но он тогда комбинирует ошибки, а не кидает только мою

onErrorReturn..

Вроде с onErrorResumeNext что-то проглянулось))

А вот если такая ситуация с rxjava:
Функция возвращает completable. Внутри себя она получает completable от некой другой операции, и теперь если completable не выкинул ошибку нужно выполнить ещё несколько запросов через другие completable источники. Вопрос в том, как в случае получения ошибки от любой из этих функций вернуть в самой основной функции completable с соответствующей ошибкой, грубо говоря completable.error. Просто когда подписываюсь на функцию внутри через subscribe, то она возвращает void...

Т.е. по сути понять как написать условие, что если функция вернула ошибку, то вернуть эту ошибку в общей функции

Если я правильно понял, тебе нужно выполнить цепочку разных completable
Чтобы выполнить completable после другого, у completable есть функция andthen
Если хоть один источник из цепочки вернёт ошибку, то её ты можешь получить в коллбеке для ошибки, который задаешь при подписке на цепочку

Это не похоже на цепочку операций, почитай про flatMap, andThen и т.д.