rx-java

0зной

1ответ

Загрузка из сети, отображение в пользовательском интерфейсе и сохранение на диск с помощью RxJava

Теперь я работаю над задачей, которая будет извлекать данные из сети, отображаться в пользовательском интерфейсе и сохранять данные в локальной базе данных для использования позже. В настоящее время я

0зной

1ответ

Как кэшировать реактивный издатель вроде Observable?

Я пытаюсь понять, что произойдет, если я кэширую результат метода, возвращающего холодный наблюдаемый? Поток еще не материализован, так что собственно кеш содержит? Я попытался выяснить использование

0зной

2ответ

SqlBrite не может использовать AndroidSchedulers.mainThread()

Я начинаю использовать sqlbrite, rxjava. Итак, я должен запустить некоторый код в потоке пользовательского интерфейса (для конкретного добавить некоторые маркеры на карте из курсора, который у меня ес

1зной

1ответ

RxJava только испускает элемент, если другой источник не будет пункт в течение некоторого периода

, имеющие две наблюдаемых Observable<Void> cancelButtonClick = RxView.clicks(btnCancel); Observable<Void> actionButtonClick = RxView.clicks(btnSomeAction) Проблема Попытки испускают з

-3зной

1ответ

NetworkOnMainThreadException когда Наблюдаемые subscrible rxjava

Я работаю с Rxjava2, Я использую flatmap в RxJava с ниже структуры: Observable1.flatmap() и вернуться к наблюдаемым 2. ниже кодов: getApi().createUser(os, deviceToken) .compose(view.regisObserv

1зной

2ответ

RXJava обработка вложенных вызовов

Предположим, у меня есть служба для извлечения некоторых авторов (id, firstname, lastname, birthday, nationality) и вторая служба для извлечения авторской книги (название, резюме, количество страниц).