В документации Reactivex.IO было указано, что Вы можете игнорировать последние n элементов,...

Допустим, у меня есть поток, выполняющий опасную операцию: void main() { Observable.just(1)

В приведенном ниже коде я вызываю метод displayAllMovies () из потока обработчика.Для Single.just в...

У меня есть состояние (Enum), которое содержит (хорошие, некритические, критические) значения Итак,...

Так как Observable.create (Emitter, BackPressureMode) имеет BackPressureMode в качестве параметра,...

У меня есть три метода 1) Получить шаблон 2) Получить поле (идентификатор шаблона) 3) Получить...

Я получаю List<User> с сервера. class User { Long localId; String remoteId; .. } Мне нужно...

Я пытаюсь отправить массив запросов в конечную точку с Observable.fromIterable(array).subscribe() с...

Предположим, у нас есть 3 службы: employeeTitle, employeeName, employeeLocation.Если все сервисы...

У меня есть Arraylist<Object>, и я пытаюсь сделать его Observable, используя rxJava, чтобы...

Я создал проект maven в Intellij IDEA, я пытаюсь выполнить приведенный ниже простой код rxjava...

У меня есть: List<T> fun1: T -> U fun2: U -> void funList: List<T> -> void Я...

У меня есть: Single<List<T>> Я хочу одновременно запустить один метод для всего списка...

У меня есть список массивов API allSignsList = ArrayList() allSignsList.add(AllSignsList(...

client.cacheLoad(((CxyAccount) account).getAccountNumber(), Cxy

У меня есть класс обслуживания API с методом, который возвращает Call, предоставленный Retrofit

Я пытаюсь получить желаемое поведение с помощью RxJava и не могу понять, как это сделать. Я хочу...

Есть ли способ вернуть значение из наблюдаемого на следующее? вот мой пример кода: public void...

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

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

У меня есть функция, которая возвращает Completable, который возвращает Completable

Рассмотрим следующий случай: Пользователь нажимает кнопку обновления несколько раз. Я хочу...

Я хочу вызвать API api1 и передать результат, возвращенный API, второму API api2.Первый API - это...

У меня есть класс Sound, который содержит медиаплеер, я хочу написать функцию, которая получает...

У меня есть набор результатов из SQL Query Builder object_key = db.select(String