Ничто из того, что я пробовал, не решает мою проблему. У меня есть три кнопки с поведением onClick. Каждая из этих кнопок вызывает один и тот же метод launchActivity , но с разными параметрами. launchActivity выполняет некоторые операции...

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

У меня есть наблюдаемое: Observable.create<Boolean> {emitter = it} , к которому я подталкиваю некоторые значения. Я хочу, чтобы он опубликовал «ложное» значение, как только прошел определенный период времени, когда какое-либо значение не было...

У меня проблема с RxJava. У меня есть метод getAll() , он возвращается со списком. Он обслуживает данные из базы данных Room. @Query("SELECT * from decks ORDER BY id ASC") fun getAll(): Flowable<List<DeckEntity>> DeckEntity...

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

Метод onNext для publishSubject вызывается непрерывно (неравномерно, примерно через 1 миллисекунду), и требование состоит в том, чтобы генерировать эти элементы каждую 1 секунду, и данные не должны теряться, значит, должен выдавать каждый элемент....

Во-первых, немного предыстории (может быть, есть лучший способ сделать это): У нас есть модуль, который отправляет входящие сообщения Bluetooth на определенный Observable. Затем мы обрабатываем эти сообщения и, наконец, подписываемся в конце,...

После нескольких дней борьбы над, казалось бы, простой задачей, я пришел к вам, ребята:) Идея проста. У меня есть два потока/наблюдаемых: «левый» и «правый». Я хочу, чтобы элементы справа буферизировались/собирались/объединялись с текущим...

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

Я пытаюсь создать службу BLE, которая будет сканировать устройства, и с помощью rxKotlin создать наблюдаемый объект, который позволит другому классу наблюдать за обнаружением устройства. Я запутался в том, как создать наблюдаемое, которое позволит...