Articles of rx android

Планировщик одиночных потоков RxJava

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

Переполнение стека при использовании Retrofit rxjava concatWith

Я хочу обрабатывать разбиение на страницы в Retrofit, используя rxjava Observable. Я последовал совету другого вопроса . У меня есть более 100 страниц, которые нужно извлечь, но цепочка выходит из строя вокруг 20-й страницы и останавливает любую дополнительную подписку на наблюдаемую с помощью следующего журнала logcat 04-04 04:12:11.766 2951-3012/com.example.app I/dalvikvm﹕ threadid=28: stack overflow on call […]

Каков правильный способ обработки подписки в RxJava / RxAndroid для жизненного цикла активности?

Я просто начинаю работу с RxJava / RxAndroid. Я хочу избежать утечек контекста, поэтому я создал BaseFragment следующим образом: public abstract class BaseFragment extends Fragment { protected CompositeSubscription compositeSubscription = new CompositeSubscription(); @Override public void onDestroy() { super.onDestroy(); compositeSubscription.unsubscribe(); } } И внутри моего фрагмента, который расширяет BaseFragment, я делаю это: protected void fetchNewerObjects(){ if(!areNewerObjectsFetching()){ […]

Не удалось удалить старое действие javaCompile, возможно, имя класса изменилось

Я изучаю RxJava. Для этого я следил за droidcon talk видео на RxJava. Инструктор дал ссылку репо для проекта, который он использовал. Я клонировал репо, когда пытаюсь построить проект на своей машине. Я получаю эту ошибку Ошибка: не удалось удалить старое действие javaCompile, возможно, имя класса изменилось? Просьба представить отчет об ошибке, с какой версией […]

Преобразование AsyncTask в RxAndroid

У меня есть следующий способ отправки ответа на пользовательский интерфейс с использованием otto и AsyncTask . private static void onGetLatestStoryCollectionSuccess(final StoryCollection storyCollection, final Bus bus) { new AsyncTask<Void, Void, Void>() { @Override protected Void doInBackground(Void… params) { bus.post(new LatestStoryCollectionResponse(storyCollection)); return null; } }.execute(); } Мне нужна помощь для преобразования этой AsyncTask в RxJava с использованием […]

Как получить тело Response при возникновении ошибки при использовании Retrofit 2.0 Observables

Я использую Retrofit 2.0 для создания вызовов api, которые возвращают Observables. Все работает хорошо, когда звонок прошел через штраф, и ответ такой, как ожидалось. Теперь предположим, что у нас есть ответ об ошибке, это вызывает onError. Я хотел бы прочитать тело ответа, даже если это ошибка. пример @FormUrlEncoded @POST("tokenLogin") Observable<LoginResponse> loginWithToken( @Field("token") String pin ); […]

Почему следует рассматривать использование AndroidObservables в RxJava

Как я понимаю, AndroidObservable помогает обеспечить: Абонент всегда наблюдает за главной нитью Когда фрагмент / активность отключается / останавливается, наблюдение немедленно прекращается, а связанные с каркасом компоненты (например, текстовые изображения и т. Д.) Не обновляются. Однако, чтобы гарантировать, что контекст будет выпущен (предотвращение утечки), большинство примеров, которые я вижу, обычно говорят, что вы все равно […]

Использовать RxAndroid или RxKotlin при программировании в Kotlin для Android?

Я собираюсь начать использовать реактивное программирование в своем проекте Android. Я использую Kotlin как основной язык, и теперь я бы хотел применить Rx. Мой первый выбор был RxAndroid, но потом я заметил, что есть RxKotlin. Насколько я знаю, оба они разветвлены из RxJava, поэтому RxAndroid, вероятно, предоставляет некоторые API для общих задач android. С другой […]

Периодические запросы HTTP с использованием RxJava и дооснащения

Можно ли использовать RxJava / RxAndroid и Retrofit для выполнения периодических HTTP-запросов для обновления данных каждые x секунд? В настоящее время я использую IntentService и Recursive Handler / Runnable, который срабатывает каждые x секунд. Я хотел бы знать, могу ли я удалить все это, и пусть RxJava обрабатывает запросы. final RestClient client = new RestClient(); […]

Как использовать CompositeDisposable для RxJava 2?

Примеры использования CompositeDisposable или одноразового использования в RxJava2. В RxJava 1 был CompositeSubscription, но этого нет в RxJava2. В rxJava2 есть что-то CompositeDisposable. Как использовать CompositeDisposable или одноразовый в RxJava2.