продуктов с сервера. Отдельные поля этих продуктов сохраняются в разные таблицы Room, которые возвращают Completable. Есть ли возможность перенести запуск методов сохранения из Observable.subscribe в какой нибудь из операторов Observable типа andThen только что бы был доступ к элементу из Observable? Или вообще как лучше всего это реализовать?
flatMap
а основной поток Observavle при этом не будет преобразован в Comletable? Мне нужно запустить цепочку Comletable один за другим
flatMapCompletable)
внутри flatMap я могу запустить цепочку из Completable?
Да, конечно
Спасибо, буду пробовать) Function1 для этого использовать?
Перед flatMap, надо flatMapIterable
да да, это я знаю)
public final Completable flatMapCompletable(Function<? super T, ? extends CompletableSource> mapper) { return flatMapCompletable(mapper, false); }
Хотя я бы вставлял инсертов все в базу одним запросом
я просто не особо знаю как мне одним запросом это сделать. Внутри продукта есть другие сущности для которых я создаю отдельные таблицы и связываю их many to many. Потом еще подтягиваю дополнительную инфу с сервера и тоже инсертю по разным таблицам
спасибо добрый человек) надеюсь получится)
😉
У completable есть функция andThen, в которой можно запустить другой completable
https://stackoverflow.com/questions/42680980/how-to-chain-two-completable-in-rxjava2
про andThen знаю, просто наверное туплю под вечер) я просто еще хотел узнать как мне сделать цепочку Сomletable внутри Observable, но при этом что бы основной поток Observable не поменялся на Completable
А, ну тогда флэтмап только
спасибо))
Обсуждают сегодня