RxJava один фоновый планировщик потока

Я довольно плохо знаком с RxJava, так что это, вероятно, глупый вопрос. Я собираюсь описать мой сценарий.У меня есть некоторый код, выполняющийся в потоке по...

Как создать Observable из OnClick Event Android?

Я новичок в реактивном программировании. Таким образом, у меня есть проблема при создании потока из события, как onClick, ontouch ...Может ли кто-нибудь помо...

 везде.

аюсь использовать rxJava, rxAndroid, Retrofit2 и OkHTTP3 для загрузки файла с конечной точки URL. Мой код не может создать адаптер вызова для «Observable &lt...

Управляйте одинаковыми запросами с помощью RxJava

Предположим, у меня есть средство извлечения, которое извлекает изображение по заданной ссылке в отдельном потоке. Изображение будет затем кэшироваться в пам...

Как прекратить Observable?

У меня есть Observable, который я хочу прекратить, если не выполнено определенное условие (то есть, если ответ от определенного веб-сайта неуспешен), чтобы я...

Реализация турникетоподобного оператора с RxJava

Как можно отписаться от PublishSubject и BehaviorSubject?

Подsubjects Пакет у вас есть классы, какPublishSubject а такжеBehaviorSubject который, я полагаю, может быть описан как полезный образецObservables. Как можно отписаться от этих тем? Здесь нетunsubscribe метод и вызовonCompleted Заканчивает ...

Применить попытки в RXjava

Я хочу запустить метод с повторными попытками, используя RXJava

Rx Java mergeDelayError не работает должным образом

Я использую RxJava и приложение для Android с RxAndroid. я используюmergeDelayError объединить два ретроспективных сетевых вызова в одну наблюдаемую, которая...

RxJava + Retrofit -> BaseObservable для вызовов API для централизованной обработки ответов

Я новичок в RxJava, поэтому, пожалуйста, прости меня, если это звучит слишком новичок :-).На данный момент у меня есть абстрактный CallbackClass, который реа...