http://reactivex.io/documentation/operators/defaultifempty.html ?

Я тоже думал об этом, но отсутствие эмита от subject

не дает эмита дальше по цепочке, в том числе от defaultifempty

А, понял. Мб как-то через флэтмап можно в последовательность что-то вкорячить, я тоже как-то пытался но так и не допер, в итоге закостылил в точке входа в цепочку нужный мне эмит

я сделал проверку значения
// Kotlin
   fun getItems(): Observable<MutableList<ItemsEntity>> =
       if (itemsSubject.value != null) {
           itemsSubject
               .map { /* ... */ }
       } else {
           Observable.just(mutableListOf<ItemsEntity>())
       }

но кажется это можно написать изящнее через rxjava

Observable.merge(itemsSubject, Observable.just(DEFAULT_ITEM))
           .firstElement()
           .map { /* ... */ }

либо так тоже работает,
я надеюсь невозможна ситуация, что DEFAULT_ITEM обгонит и перекроет значение из сабжекта

Startwith используй и точно не обгонит. Я не помню порядок мержа

последний пункт невозможен. все подписчики равны. все что можно отыграть - подписаться позже и получить только те события, которые возникли после подписки. а нормальный вариант решения - делать новый стрим из текущего - для первого исходный, для остальных скипая элемент. либо наоборот: для остальных исходный, а для первого с startWith

но раз такой вопрос, то видимо неизвестно кто первый)

архитектура цепочки такая, что желательно бросить только одно значение.

Всем привет 👋 есть какие нибудь идеей как реализовать такое:

Есть лист чекбексов : 10
При чек надо отправлять в сервер запросы

Мое решение:
. subscribe (Schedulers.newThread())
. observeOn(AndroidSchedulers.mainThread())
.onNext(lambda)
.onError(errorMesaage)
.await()

Проблема: каждый раз запускает новый поток , если быстро чекать то потоки то ли не успевают создаваться либо ещё чего-то


Подскажите пожалуйста или дайте совет как это нормально реализовать?

Мне кажется это уже проблема в архитектуре интерфейса

Зачем при каждом чеке что-то отправлять ?

Что за кейсы такие ?)

Аналог лайка , сервер же предоставляет данные картинки что она лайкнута или нет

Нормальная ли практика юзать Single.just для превращения синхронных функций в реактивные?

Ну да, почему бы и нет

Всем привет, только начинаю изучать RxJava. Такая ситуация, загружаю список продуктов с сервера. Отдельные поля этих продуктов сохраняются в разные таблицы Room, которые возвращают Completable. Есть ли возможность перенести запуск методов сохранения из Observable.subscribe в какой нибудь из операторов Observable типа andThen только что бы был доступ к элементу из Observable? Или вообще как лучше всего это реализовать?