У меня есть api rest, который возвращает список мест, в которых есть список категорий: {...
RxTextView.textChanges(editText) .map(CharSequence::toString) .debounce(200, TimeUnit.MILLISECONDS)
Я пытаюсь протестировать некоторый код RxJava, используя TestSubsriber.Данные поступают из Room ORM...
Предположим, что есть 3 потока, T1, T2, T3.Как я могу заставить их работать последовательно, скажем...
Примечание : Оказывается, toCompletable() не был ошибкой, но вместо этого это был код вызова.Код...
Я пытаюсь отфильтровать список после получения входных данных от edittext, на самом деле это...
Я хочу найти весь список элементов, которые будут найдены до того, как я завершу, и если весь этот...
У меня есть две следующие функции Single: fun getStrings(): Single<List<String>> {...
Я хочу собрать первые выбросы от двух вызовов методов, которые могут быть достигнуты с...
Я пробую основы RxJava2. override fun onCreate(savedInstanceState: Bundle?) { super
Я использую RxJava throttleFirst в течение одной секунды, чтобы избежать быстрых нажатий кнопок,...
изучаю switchMap.Случай таков: 1) Пользователь нажимает кнопку 1 2) Просматривает вызовы метода...
Рассмотрим следующую наблюдаемую цепочку Observable.just(1). doOnSubscribe(disposable -> Log
Я уже некоторое время использую RxJava.Я использую операторы subscribeOn и observeOn для управления...
Я пытаюсь понять концепции, лежащие в основе реактивного программирования, и в настоящее время я...
Я использую комнату базы данных и RxJava.Мне нужно удалить все записи из таблицы, а затем вставить...
Как связать Single с Completable таким образом, чтобы он подписывался после завершения Completable?...
Ниже приведен мой фрагмент кода, и иногда Observable не срабатывает, Observable<A>...
У меня серьезная проблема с Room и RxJava2.Я не могу выполнить некоторые операции с базой данных...
Я пытаюсь разобраться в чем-то в RxJava.Я подписываюсь на Наблюдение за изменениями в Realm, а...
Используя RxJava на Kotlin Android, я делаю следующее: У меня есть функция для создания растрового...
У меня есть сценарий, где у меня есть subject1: PublishSubject и subject2:BehaviorSubject. Сначала...
Подписчик не получает никаких данных от Flowable.Ни onNext (), ни onError () не вызываются.Но когда...
Некоторые методы RxJava, такие как just, вызывают создание массива непроверенных обобщений для...
Привет, я новичок в RXJava. Я пытаюсь получить Users из нескольких Observable, которое содержит...