Если же ставим флаг isError в true - и снова s2.acceptValue - выводит ошибку на doOnError

Дальнейший s2.acceptValue не дает результата, потому что в s1 ничего нет

Добрый день, есть следующий кусок кода

Я хочу преобразовать его в rxjava

Есть какие-то советы?

.toFlowable вроде был оператор

Спасибо

Всем привет

Есть вопрос

как мне  в subscribe после flatmap получить доступ к responseToken?

Его надо вернуть в flatMap

Раз уж тебе нужны 2 объекта то юзай Pair<ResponseToken, DriverData>

День ЗП

Всем, привет. Я новичок с rxjava, может мне кто-нибудь простым языком объяснить зачем нужен BehaviorProcessor и чем он так отличается от тех же observable различных

Короче, как я понял это тот же observable только hot backpressuer aware. Поправьте если ошибаюсь

Доброе утро парни. Подскажите с rxJava, как говорится best practice нужен. У меня есть boundaryCallback для paging'a, откуда делается апи запрос, который возвращает айтемы и сохраняет их в базу данных. Нужно обернуть это в rxJava. Делаю это следющим образом
Compleatable.fromCallable(...)
.subscribeOn(io)
.observeOn(mainThread())
.subscribe(CompleatableObserver)

Чтобы исправили, добавили или убрали? И не нужно ли мне вернуть disposable?

Да в этом чате вообще есть живые?