Как concatEagerDelayError в RxJava2

Как реализовать Observable.concatEagerDelayError или эквивалент в RxJava2/RxKotlin2?

Есть :

Observable.concatEager
Observable.concatDelayError

Но нет :

Observable.concatEagerDelayError

Что я имею :

fun getAll(): Observable<List<User>> = Observable.concatArrayDelayError(
    // from db
    userDAO
        .selectAll()
        .subscribeOn(ioScheduler),
    // from api
    userAPI
        .getAll()
        .doOnNext { lstUser -> Completable.concatArray(
            userDAO.deleteAll().subscribeOn(ioScheduler),
            userDAO.save(lstUser).subscribeOn(ioScheduler)
        ) }
        .subscribeOn(ioScheduler)
)

Я хочу такого же поведения, но с нетерпением жду selectAll() и getAll(), потому что нет причин ждать от db запуска сетевого вызова.

rx-java2 rx-kotlin2

13.03.2019 11:01

Стоит ли изучать PHP в 2026-2027 годах?

Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией

В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.

Приемы CSS-макетирования - floats и Flexbox

Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...

Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest

В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...

Концепция локализации и ее применение в приложениях React ⚡️

Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

154

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Используйте concatMapEagerDelayError:

 Observable.fromIterable(sources)
 .concatMapEagerDelayError(v -> v, true);

 Observable.fromArray(source1, source2, source3)
 .concatMapEagerDelayError(v -> v, true);

JavaDoc.

Редактировать:

fun getAll(): Observable<List<User>> = Observable.fromArray(
    // from db
    userDAO
        .selectAll()
        .subscribeOn(ioScheduler),
    // from api
    userAPI
       .getAll()
       // --- this makes no sense by the way -------------------
       .doOnNext { lstUser -> Completable.concatArray(
            userDAO.deleteAll().subscribeOn(ioScheduler),
            userDAO.save(lstUser).subscribeOn(ioScheduler)
       )}
       // ------------------------------------------------------
       .subscribeOn(ioScheduler)
)
.concatMapEagerDelayError({ v -> v }, true)

Я отредактировал исходный вопрос с большей точностью. Я не думаю, что это ответ. Или вы можете привести точный пример для моего случая?

— 14.03.2019 14:32

Я обновил свой ответ. Пожалуйста, в следующий раз предоставьте всю необходимую информацию заранее.

— 14.03.2019 14:42

Спасибо и извините. Можете ли вы объяснить мне, почему обновление базы данных не имеет смысла?

— 14.03.2019 14:44

Вы создаете и выбрасываете Completable в doOnNext. Сомневаюсь, что это работает, а если и работает, то вы делаете что-то гораздо хуже в userDAO.

— 14.03.2019 14:46

Вызов для удаления и сохранения протестирован. Но, может быть, вы предложите другой способ сделать то же самое?

— 14.03.2019 17:30

Я бы предложил flatMapCompletable вместо doOnNext.

— 14.03.2019 18:42

Спасибо. Может лучше оставить doOnNext и не возвращать Completable за deleteAll и save ?

— 20.03.2019 13:15

14.03.2019 13:50