У меня есть класс, который принимает Observable и подписывается на него. static class Helper { void...
Я пытаюсь обработать ошибку (игнорировать ее), когда она возникает в моем верхнем наблюдаемом...
У меня есть следующее в RxJava 1, которое возвращает Observable<SomeObject>: // objects is a...
Рассмотрим следующий пользовательский случай: Iterable<Object> it =...
Я пытаюсь сделать вызов webservie, используя retrofit и rxjava 2. Я изучал два разных подхода к...
Я хочу сделать две вещи: загрузить некоторые данные на сервер, а затем сохранить данные в локальной...
Для LiveData, есть ли что-то похожее на blockingNext или blockingSingle в Observable в RxJava для...
В документации Подписка # отменить говорится, что Data may still be sent to meet previously...
Вот так выглядит мой запрос: ApiService apiService = retrofit.create(ApiService.class);...
Каковы правильные концепции и работы observables и наблюдателей в RxJava. Я запутался в словах...
Я работаю с rxjava2. Моя проблема в том, что иногда сервер не отправляет мне ничего (тело ответа...
Я хочу загрузить несколько изображений на сервер, используя модификацию / RxJava один за другим, а...
Я пытаюсь работать с библиотекой RxJava для Bluetooth на Android. Мои требования: Наблюдаемый для...
Я использую Room в проекте, и у меня есть следующий интерфейс DAO: @Dao interface BalanceDao {...
Я пытаюсь проверить Retrofit API с помощью Spek Выдает исключение nullPointerException для в {...}...
Я работаю с RxJava и хочу объединить свою цепочку с чем-то вроде boolean -flag (в моем случае...
Версии оператора buffer, которые не работают по времени, учитывают противодавление согласно...
Observable.create(new ObservableOnSubscribe()) .subscribeOn(Schedulers.io()) .compose(new...
PagedList<Object> используется для классной библиотеки подкачки Android.Чтобы вопрос был как...
Я хочу запросить услугу для данных с интервалом. Я использую Observable.interval для достижения...
Хотя один из рельсов испускается onError(), isCancelled() в других рельсах все равно возвращает...