А зачем это нужно, если сервер больше одного раза не ответит?
Тут корректнее написать Single вместо Observable

А как вообще Observable влияет на перфоманс в отличии от Single?

Я не шарю так глубоко за Rx и не могу сказать влияет ли это на Perfomance
Но с точки зрения восприятия и чистоты коды запросы из сети как правило Single, запросы из БД как правило Maybe, когда у репозитория есть какая-то логика кеширования, он как правило данные отдает порциями и в нем содержится Flowable/Observable

Ну и если было бы понимание, что запрос из сети как правило Single, то не было бы подобных вопросов, которые задавали выше

Почему такая цепочка не завершается?

fun foo(): Completable {
  return flowable.flatMapCompletable { 
    Completable.complete() 
  }
}

А вот эта завершается

fun foo(): Completable {
  return flowable.flatMapSingle { 
    Completable.complete().andThen(Single.just(Unit)) 
  }
}

Можно как-то обойтись без andThen(Single.just(Unit)) ?

и напрямую из flatMapCompletable вернуть результат, чтобы цепочка шла дальше

fun foo(): Completable {
  return flowable.flatMapCompletable { 
    Completable.complete() 
  }
}

fun foo(): Completable {
  return flowable.flatMapSingle { 
    Completable.complete().andThen(Single.just(Unit)) 
  }
}

она завершается. вот пример https://pastebin.com/mUA9zE7d

ты скорее всего на вход этим методам передаешь разные flowable, один из которых завершается ,а второй нет

Парни знает кто-то статью с примером использования room ili retrofit  в связке с rxjava ну или код если есть

Вот в этом туториале есть урок отдельный по переходу от колбэков к rxJava в retrofit https://androidschool.ru/courses/android-retrofit-and-gson/

Спасибо

Всем привет. Что-то ничего в голову кроме костылей не приходит, может сообщество чего посоветует...

            .flatMap {
                if (condition) {
                    Completable.fromAction{ ... }.andThen(Observable.empty<SomeObj>().toSingle())
                } else {
                    pushesRepository.getPushesFromServer(SomeObj()).doOnSuccess {...}
                }
            }.flatMap {
                userRepository.sync()
                        .doOnSuccess {...}
            }

После этого кода еще длинная цепочка выполняется. Задача: нужно чтобы если condition == true цепочка дальше не выполнялась. У меня получился только такой костыль, но я помню что кидаение ошибок (а тут де-факто оно и есть) - неправильный способ завершать последовательность, если таковым образом предусмотрено ее завершение. Сделать все Completabl-ами я не могу, т.к. есть doOnSuccess у !condition и цепочка предусмотрена в flatMap -ах Single

            .flatMap {
                if (condition) {
                    Completable.fromAction{ ... }.andThen(Observable.empty<SomeObj>().toSingle())
                } else {
                    pushesRepository.getPushesFromServer(SomeObj()).doOnSuccess {...}
                }
            }.flatMap {
                userRepository.sync()
                        .doOnSuccess {...}
            }

Ну подожди есть же оператор фильтр и после фильтра ничего лишнего не выполняется. ?🤔

Я что-то упустил или у Сингла таки есть фильтр?

takeUntil и прочие тоже не предлагать, они у обсерваблов только

Тогда может просто у Completable вызвать .complete во flatMap?

Может использовать Maybe или Observable если может вернуться что-то или ничего или ошибка.

rx1  - мейби нет

нужно чтобы синглы шли дальше по цепочке, не комплитаблы, плохо читаете условия