Я недавно использую rx kotlin и еще не все понял.Я пытаюсь перебрать список запросов и выполнить их...

Я связываю два Completables с "andThen", однако кажется, что метод subscribe () никогда не...

Я использую Room для управления базой данных, и я не знал, что использовать при работе с данными в...

Есть много отличных постов и статей, объясняющих FlatMap и SwitchMap, но Я спрашиваю здесь...

У меня сейчас есть следующий код: def method(): Future[State] = Future { // some processing State

я пытаюсь получить массив потоковых данных, выполняемых параллельно с FlowableFromArray и испускаем...

Я создаю рабочую очередь на основе таблицы PostgreSQL. У меня есть Observable из INSERT событий в...

мой текущий код private final List<Disposable> subscriptions = new ArrayList<>(); for...

refCount ведет себя неожиданно в этом случае использования. Это похоже на то, что при...

Я пытаюсь создать Observable, используя Futures с сопрограммами. Вот что я попробовал: private fun...

Консоль ничего не печатает после исключения этих кодов ConnectableObservable o =...

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

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

Я хотел бы знать, как я могу разорвать связь между наблюдаемыми и наблюдателем раньше, чем все...

Я хочу реализовать некоторый код, который обнаружит любое изменение файла (txt, doc, pdf и т. Д.),...

У меня есть функция в RxJava, которая пытается найти вещь на основе условия, и в случае успеха она...

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

Я пытаюсь использовать Fountain (https://github.com/xmartlabs/fountain), чтобы помочь мне...

В примере Javadoc Observable.retryWhen, AtomicInteger используется для counter вместо простого...

У меня есть блок кода, может понравиться. fun main() { foo() .flatMap { bar() } .subscribe({}, {...

Предположим, у меня есть Observable, и он будет излучать не более 1 элемента. Я бы хотел сделать...

Как показано ниже, я создаю Observables. Когда я пытаюсь применить оператор faltMap, я получаю...

Я пытаюсь использовать RxJava для итерации по двум массивам, накапливать результаты во внутреннем...

Я пробовал решения, упомянутые уже в stackoverflow, и мой код выглядит следующим образом (new...

У меня есть приложение для Android с архитектурой MVVM. Слой вида (фрагмент) подписывается на...