Articles of rx java

Rx java retrofit 2 обработка ошибок

Я использую retrofit 2 вместе с rx java Ситуация: приложение отправляет некоторый запрос, затем я получаю ответ в json-формате, который автоматически преобразуется в User dto, затем в метод onNext из rx java я получаю список пользователей. Что делать, если я получаю сообщение от сервера следующим образом: {"error": "не может получить список пользователей"} Как справиться с […]

RxJava: Как сделать однократное повторное использование?

При каждом запуске приложения у меня есть Retrofit Observable, который извлекает имя пользователя пользователя с сервера. Я хочу использовать это значение для каждого последующего абонента, но кажется, что каждый раз, когда я вызываю subscribe (), значение повторно выбирается из сети. Поскольку имя пользователя вряд ли изменится во время жизненного цикла приложения, я не воссоздаю объект […]

Цепочные RxJava наблюдаемые с обратными вызовами / слушателями

Я использую Retrofit с Observables и хотел бы связать наблюдаемые. Обычно он хорошо работает с такими функциями, как map() или flatMap() , поскольку api возвращает Observable, который выполняет задачу. Но в этом случае я должен сделать следующее: GetKey () из api Используйте возвращенный ключ в другой библиотеке Foo и дождитесь вызова callback. Когда обратный вызов […]

Существует ли правильное правило proguard для RxJava и FasterXML?

Теперь единственная проблема, мешающая мне использовать kotlin в производстве, заключается в том, что я не могу найти для нее правильный файл proguard. То, что я использовал: 1.Kotlin 2.Anko 3.Jackson-Котлин-модуль Вот предупреждение: :app:proguardRelease Warning: com.fasterxml.jackson.databind.ext.DOMSerializer: can't find referenced class org.w3c.dom.bootstrap.DOMImplementationRegistry Warning: rx.internal.util.unsafe.BaseLinkedQueueConsumerNodeRef: can't find referenced class sun.misc.Unsafe Warning: rx.internal.util.unsafe.BaseLinkedQueueProducerNodeRef: can't find referenced class sun.misc.Unsafe Warning: rx.internal.util.unsafe.ConcurrentCircularArrayQueue: […]

RxAndroid и Retrofit: невозможно создать адаптер вызова для io.reactivex.Observable <retrofit2.Response <okhttp3.ResponseBody >>

Я пытаюсь использовать rxJava, rxAndroid, Retrofit2 и OkHTTP3 для загрузки файла с конечной точки URL. Мой код не может создать адаптер вызова для «Observable <retrofit2.Response <okhttp3.ResponseBody >>». Эти методы новы для меня, поэтому я считаю, что здесь отсутствует важная концепция. Любое направление или баллы приветствуются. FATAL EXCEPTION: main Процесс: com.example.khe11e.rxdownloadfile, PID: 14130 java.lang.IllegalArgumentException: невозможно создать […]

Android AsyncTask vs Thread + Handler vs rxjava

Я знаю, что это вопрос, который задавали много раз. Однако я не нашел ответа. Так что, надеюсь, кто-то может пролить мне немного света. Мы все знаем, что AsyncTask и Thread – это опции для выполнения фоновых задач, чтобы избежать проблемы ANR. Рекомендуется, чтобы asynctask использовалась только для коротких задач, тогда как поток можно использовать для […]

Тестирование эспрессо с помощью RxLoader

У меня есть активность, которая использует RxLoader для извлечения данных с сервера при создании активности и заполняет представление списка. У меня также есть тестовый код, который пытается щелкнуть по первой строке списка после его заполнения. Поскольку я использую RxLoader, я должен написать индивидуальный IdlingResource для Espresso. Однако проблема заключается в том, что тест заканчивается (сбой) […]

Тест-драйв Robolectric + OkHttp + retrofit + rxJava

Я пытаюсь написать единичный тест для куска кода с robolectric. Проблема в том, что мне нужно подделать http-вызов, но кажется, что поддельный слой robolectric работает только с HttpClient Apache в соответствии с этим ответом: Ссылка на ответ В «Дооснащении» вы не можете изменить URL-адрес, поэтому MockWebServer, по-видимому, не является вариантом. Кажется, что mockito может перехватывать […]

Тестирование JVM-модуля с помощью Mockito для тестирования Retrofit2 и RxJava для сетевых запросов

Android Studio 2.3 RC 1 Я использую архитектуру MVP и хочу запускать модульные тесты JVM. В моей модели я использую Retrofit2 и RxJava для извлечения фильмов из API. Я хочу проверить функцию getPopularMovies(…) Однако эта функция вызовет веб-сервер. Тем не менее, в тесте я хочу как-то издеваться над этим и просто проверить onSuccess() и onFailure() […]

Правильный способ управления сетью с помощью дооснащения и RX-java

Я хочу проверить, подключен ли мобильный телефон к Интернету, прежде чем использовать мою услугу rx retrofit. Если не подключен, я хочу вернуть фальшивый ответ, содержащий ошибку. Я закончил решение ниже, используя defer (), но я думаю, что это может быть лучше, любые подсказки? private Observable<Response> checkNetwork(Observable<Response> retrofitService) { return Observable.defer(new Func0<Observable<Response>>() { @Override public Observable<Response> […]