Посмотри в блоге есть статья. В ней, в числе прочих, даётся и твой юскейс

Ок

После онкомплит обсервер уже не выдаст данные?

От такого обсервера надо отписываться?

нет

от того на который подписался

Ок

Даже если ему оннекст вызвать?

❗️❕Еще не получил скидку на Binance? Тогда забирай 👇
Чтобы получить скидку 20% на комиссию биржи - регистрируйтесь по ссылке ниже либо введите промокод при регистрации: GHA1UMA6

https://www.binance.com/ru/register?ref=GHA1UMA6

После регистрации - скидка остаётся на аккаунте навсегда

А room уже поддерживает rxjava3?

Подскажите, где можно найти мануалы на русском с самого нуля? В шапке на русском только примеры, а где почитать про disposable, flowable, их разницу и т.д.?

Благодарю, а часть 2 так и не вышла?

Ой, а я забыл что там нет второй части

https://habr.com/ru/company/badoo/blog/328434/

вот замена, там про Signle и тд

Спасибо, буду изучать

Приветствую. Подскажите, правильно ли подписываться на данные внутри doOnSubscribe?

.doOnSubscribe(disposable -> {
                   showProgressBar(true);
                   taskRepository.getItems()
                           .subscribeOn(Schedulers.io())
                           .subscribe(items -> {
                               taskRepository.addItems(items);
                           }, e -> Log.e(TAG, e.getLocalizedMessage()));
                   taskRepository.getStaffs()
                           .subscribeOn(Schedulers.io())
                           .subscribe(staffMobiles ->         taskRepository.addStaffs(staffMobiles), e -> Log.e(TAG, e.getLocalizedMessage()));
               })
               .subscribe(taskList -> {

И вот такой второй момент сабскрайб в сабскрайбе

.subscribe(taskList -> {
                   if (taskList.isEmpty()) {
                       taskRepository.getRemoteTasks()
                               .subscribeOn(Schedulers.io())
                               .subscribe(taskList1 -> {
или надо как-то реализовать с помощью операторов?