Articles of rx android

Функция отладки RxJava2 не работает должным образом в RecyclerView – Android

Я пытаюсь создать пользовательский ImageButton, который будет накапливать клики и запускать событие, когда пользователь перестанет нажимать кнопку в течение 1 секунды. Для выполнения этой функции я использовал функцию debounce. Пользовательский ImageButton: public class MBImageButton extends ImageButton { private AtomicInteger mCounter; private Disposable mDisposable; private Observable<Object> observable; private OnAccumulatedRequestsRead mOnAccumulatedRequestsRead; private OnEverClickListener mOnEverClickListener; private int emitEveryMilli […]

RxJava, выполнить код в потоке наблюдателя, прежде чем связывать два наблюдаемых

Я использую RxJava и RxAndroid, и я хочу объединить два наблюдаемых, но между ними мне нужно обновить интерфейс, поэтому я должен выполнить код в основном потоке, прежде чем достигнуть подписчика. Одно решение, а не flatmapping (это принятый термин?) Два наблюдаемых, было бы назвать следующее наблюдаемое в подписчике сразу после обновления пользовательского интерфейса, но я чувствую, […]

RxJava с презентатором и сохраненным фрагментом для изменений конфигурации

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

Как получить тело ответа с помощью RxAndroid и дооснастить 2?

Я использую Retrofit 2 (beta 4), и я искал переход от использования стандартного ответа на ответ RxAndroid Observable . Мне удалось переключить большинство моих вызовов с помощью простой свопинга из Call<List<ExampleObject>> в Observable<List<ExampleObject>> . Некоторые из моих вызовов используют Call<okhttp3.ResponseBody> , который отлично работает, но когда я поменял Call , меня встретила ошибка: 03-03 15:21:44.237 […]

Дооснащение по умолчанию

Я использую Retrofit с RxJava в своем приложении для Android, а мой код: public void getConfig(NetworkSubscriber subscriber) { Observable<Config> observable = mApi.getConfig(); observable.subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber); } public void getCode(String mobile, int type, NetworkSubscriber subscriber) { Observable<BaseMessageEntity> observable = mApi.getCode(mobile, type); observable.subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber); } И я не хочу писать .subscribeOn(Schedulers.newThread()) и .observeOn(AndroidSchedulers.mainThread()) каждого бизнес-метода Как […]

Proguard и RxAndroid V1.1.0

Я не могу заставить Proguard работать с библиотекой RxAndroid v1.1.0. Раньше я использовал v1.0.1, и это отлично работало со следующим правилом. -dontwarn rx.internal.util.unsafe.** Однако после обновления до v1.1.0 rxAndroid, а также RxJava, как он говорит в файле Github ReadMe.txt, я получаю это исключение, когда я использую RxAndroid в своем коде. Caused by: java.lang.NoSuchFieldException: producerIndex Поэтому […]

Как создать Observable в Android?

Что я хочу сделать, так это создать простой кеш в памяти, чтобы попробовать Observables. Однако я застрял, потому что не понимаю, как создать наблюдаемый. Это код, который я получил до сих пор: public class MovieCache { MovieWrapper movieWrapper; public Observable<MovieWrapper> getMovies() { //How to create and return an Observable<MovieWrapper> here? } public void setCache(MovieWrapper wrapper) […]

Почему RxJava с доработкой на Android doOnError () не работает, но Subscriber onError делает

Может кто-нибудь объяснить мне, почему код выглядит так: networApi.getList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .doOnError(throwable -> { throwable.getMessage(); }) .doOnNext(list -> { coursesView.populateRecyclerView(list); courseList = (List<Course>) courses; }).subscribe(); Если в DoOnError нет Интернета, он добавляет его дальше, поэтому приложение не работает, но код выглядит следующим образом: networkApi.getList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<List<? extends Course>>() { @Override public void onCompleted() […]

Использование RxJava для извлечения объекта, преобразования содержащего списка и использования списка

Проблема высокого уровня, которую я пытаюсь решить, заключается в преобразовании списка объектов Foo содержащихся в извлеченном FooContainer (Observable), в список объектов FooBar с использованием RxJava. Моя (запутанная) попытка: fooContainerObservable .map(container -> container.getFooList()) .flatMap(foo -> transformFooToFooBar(foo)) .collect( /* What do I do here? Is collect the correct thing? Should I be using lift? */) .subscribe(fooBarList -> […]

Как обновить интерфейс от Android-сервиса, используя RxJava / RxAndroid

У меня есть служба Bound, которая отвечает за загрузку файлов и, следовательно, знает статус загрузки / прогресс. И пользовательский интерфейс (фрагмент или действие) должен показывать / обновлять загрузку с услуги. На самом деле я считаю, что общий способ – использовать BroadcastReciever или CallBack из Activity. Но я где-то слышал о том, как использовать RxJava (ReactiveX […]

Intereting Posts
Как использовать ExecutorService с Android AsyncTask? Android: Полный контроль над телефоном (режим киоска), возможно ли это? Как? Android Custom IME использует по умолчанию на экранной клавиатуре Способ получить разблокировку в андроиде? Шифрование с помощью модуля Node.js Crypto и расшифровка с помощью Java (в приложении для Android) Android expandablelistview, как установить пространство между элементами групп Как отключить подключение к Интернету в Android Emulator? Как открыть Gmail Compose при нажатии кнопки в приложении Android? Как справиться с необходимостью межпроцессного взаимодействия в моем приложении Android? Android fastboot ждет устройств Некоторые устройства не получают уведомления FCM Как создать пользовательский BaseAdapter для AutoCompleteTextView Вызов функции finish () из активности освободит мое пространство памяти? Как отключить выделенную строку в MPAndroidChart? Как проверить, подписана ли APK или «отладить сборку»?