12
ответов

java.lang.NullPointerException: плагин возвращает null Observer [дубликат]

Я искал NullPointerException: плагин вернул null Observer, но не нашел полезного исправления. Я нашел эту проблему в Crashlytics, поэтому у меня нет сценария для ее создания. Полная ошибка ...
вопрос задан: 26 May 2016 16:15
4
ответа

Как мне обработать исключения в map () в Observable в RxJava

Я хочу сделать это: Observable.just (bitmap) .map (new Func1 < Bitmap, File > () {@Override public File call (Bitmap photoBitmap) {// ...
вопрос задан: 30 April 2017 06:27
3
ответа

AndroidSchedulers.mainThread наблюдает onError раньше, чем onNext [duplicate]

Сегодня я застрял, поскольку у меня были проблемы с AndroidSchedulers.mainThread () Observable.create (emitter - & gt; {emitter.onNext (1); emitter.onNext (2); emitter.onNext (3); // Thread.sleep (10), ...
вопрос задан: 21 August 2015 16:09
2
ответа

Запросите несколько REST API одновременно

Моя цель - запросить двойной REST API одновременно с Retrofit, и их ответы - List. Я хочу обработать каждый ответ для обновления в View (ответ 1 в порядке -> View1 показать данные, response2 это ...
вопрос задан: 6 March 2019 13:22
2
ответа

Как отправить пользовательский бросок через flatmap в RxJava на Android?

Поэтому я использую flatMap с RxJava для объединения некоторых вызовов API, которые возвращают Singles, и мне было интересно, как передать пользовательский метод throwable методу подписки в метод flatmap, в зависимости от моего собственного ...
вопрос задан: 18 January 2019 18:51
1
ответ

RX-Android + ViewModel + Retrofit не вызывает OnComplete ()

Я не могу получить метод OnComplete () для вызова после обработки всех элементов. Мне нужно сделать это для того, чтобы (как минимум, скрыть представление загрузки). Я немного новичок в JavaRX, поэтому я не знаю, где ...
вопрос задан: 2 March 2019 23:17
1
ответ

Правильная операция приема для слияния двух наблюдаемых

Я написал ниже класс для доступа к своему репо, который включает в себя как удаленное, так и локальное репо. открытый класс VenuesRepoImpl реализует VenuesRepo {private VenuesLocalRepo venuesLocalRepo; частный ...
вопрос задан: 25 February 2019 15:08
1
ответ

Использовать случайное наблюдение x количество раз

У меня есть Observable, который реализует обработку ошибок в методе onErrorResumeNext. getMyObservable (params) .take (1) .doOnError (e - & gt; {}) ...
вопрос задан: 13 July 2018 07:17
0
ответов

Robolectric реактивная блокировка First () иногда зависает

Этот тест выглядит нормально и работает нормально. Тем не менее, иногда это занимает навсегда метод blockingFirst (). @Test fun test_getScenarioModel () {doReturn (MockDownloader ({File ("abc.zip")})) ....
вопрос задан: 17 January 2019 05:27
0
ответов

RxJava2 успех всегда вызывается дважды

Я реализую архитектуру MVP с Retrofit и RxJava2 (с RxAndroid). У меня есть следующие настройки NetworkInterface.java, где вызовы модернизации лежат общедоступный интерфейс NetworkInterface {@ ...
вопрос задан: 16 January 2019 07:31
0
ответов

Когда использовать RxJava в Android, а когда использовать LiveData от Android Architectural Components?

У меня нет причины использовать RxJava в Android и LiveData от Android Architectural Components. Было бы очень полезно, если бы примеры использования и различия между ними были объяснены вместе ...
вопрос задан: 24 April 2018 16:36
0
ответов

Немедленно доставить первый товар

Рассмотрим следующий вариант использования: необходимо доставить первый элемент как можно скорее, необходимо отменить последующие события с 1-секундным тайм-аутом. В итоге я реализовал пользовательский оператор на основе ...
вопрос задан: 9 May 2015 12:40