Я пытаюсь создать серверный вызов, используя библиотеку RxJava2, которая попытается опросить сервер...

Попытка построить реактивную систему с использованием akka, rx, vert.x and mongodb, где поток...

У меня есть две разные наблюдаемые, которые ведут себя как Наблюдаемое одно поведение -> Это будет...

Я хочу представить выполнение внешнего процесса как Observable[String], где String - строка из...

Этот тест выглядит нормально и отлично работает. Однако, иногда, метод blockingFirst () занимает...

Я никогда не мог понять разницу между blockingSingle и blockingFirst на Observables в RxJava. Любая...

Я занимаюсь разработкой приложения для Android с использованием модификаций и rxjava. В основном у...

Как правильно выполнить приведенные ниже тесты с использованием rxjava2? Имея список серверов ntp,...

onNext метод publishSubject вызывается непрерывно (в разное время, примерно за 1 миллисекунду) И...

Я работаю с этим кодом, мне нужно создать рекурсивный метод в rxjava, который возвращает и...

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

Я работаю со следующим кодом: override fun getSportList(dCSServiceContext: DCSServiceContext):...

Я выполняю сетевой вызов, в котором я .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers

Я видел использование RxImmediateSchedulerRule для переопределения планировщиков для тестирования....

ниже мой .xml <data> <variable name="featureProductModel" type="com.mca

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

Приведенный ниже код печатает один UndeliverableException для второго потока внутри метода publish....

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

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

Я хотел попробовать RxJava с kotlin, чтобы упростить кодирование, поэтому я произвел это: fun...

Вот код: getUsersObservable() .subscribeOn(Schedulers.io()) //.observeOn(AndroidSchedulers

У меня есть следующий метод, который возвращает Single: override fun...

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

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

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