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

Я заблудился в rx.Observable API и мне нужна помощь. Я бы хотел удалить большую часть документа в...

Скажем, у меня есть Observable, который я создал из итерируемого или массива. Если я сопоставляю...

Я пытаюсь реализовать библиотеку разбивки на страницы, используя rxJava. Прежде всего, я вызываю...

У меня есть приведенный ниже пример кода val disposable = Observable.interval(interval, TimeUnit

Документация для RxJava Observable.empty() сообщает: создать Observable, который не испускает...

Ранее я использовал MediatorLiveData для объединения результатов из FCM, Room и Networking в моем...

У меня проблема с исключением getCurrentUpdateDateFromStorage () java.util.NoSuchElementException:...

Я хочу выполнить что-то, когда установлены оба units и variables (через Single<T>, НЕ...

Как разделить отдельный поток на отдельные отдельные потоки, чтобы я мог выполнить следующее, не...

В моем приложении для Android у меня есть сгенерированный (Swagger) ApiClient, который...

У меня проблема с оператором take(5) в rxjava. Не знаю почему subscribe {ui.showLikes(it)} всегда...

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

У меня есть код, который выполняет операцию блокировки в цикле while (загружает некоторые данные с...

Я пытаюсь проверить этот код с помощью mockito. public class Repository { ... @Override public...

Не уверен, правильно ли я использую эту функцию. У меня есть много потоков, которые добавляют...

Я создаю список Observable, используя список значений, для каждого значения пользовательский...

Я нуб в RxJava, но когда-нибудь ...; ) Что у меня есть: Получение JSON с моделью планировщика...

Я хочу использовать PublishSubject + debounce (в логике подписки) для отправки моих товаров с...

У меня есть этот метод, который я пытаюсь получить данные из API, а затем обновить текстовое...

Мне нужна функциональность, которая позволяла бы асинхронно отправлять сообщения на мой...

Я прочитал некоторые проблемы RxJava2 о сбое после вызова dispose() в Observable здесь и здесь ....

Я использую Rx на Android в редактируемом текстовом поле. Я хочу получить исходный пользовательский...

У меня есть одна наблюдаемая, которая выдает значения от 0 до 10 за каждую секунду. Мне нужно...

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