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