Articles of rx android

RxAndroid отказывается от карт google при смене камеры

У меня есть приложение, которое использует карты Google и прослушивание смены камеры. Моя проблема заключается в том, что при каждой смене камеры я должен запросить мой сервер. Я хочу просто ограничить количество запросов, используя RxAndroid / Java для отладки. Мой код выглядит так: Observable.create(new Observable.OnSubscribe<CameraPosition>() { @Override public void call(Subscriber<? super CameraPosition> subscriber) { if […]

RxJava: Как возобновить работу наблюдаемого, если происходит изменение конфигурации?

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

В RxJava, как повторить / возобновить ошибку, вместо завершения наблюдаемого

Я хочу достичь: Отслеживать предпочтения для определенного изменения Когда обнаружено изменение, запустите новый сетевой вызов, используя новое значение Преобразовать результат Отображение результата в пользовательском интерфейсе Я знаю, когда произойдет изменение, теперь я полагаю, что мне нужно вызвать onNext на тему. Затем это должно инициировать цепочку Rx, и в конце я могу обновить интерфейс. mViewPeriodSubject = […]

Совместное использование RxBindings Наблюдаемые события между несколькими подписчиками

Я использую Focus Observable из библиотеки RxBindings, чтобы реагировать на изменения фокусировки. Поскольку я хочу либо проверять ввод и запускать анимацию, мне нужны события фокуса дважды. Джейк Уортон рекомендует использовать оператор share () для нескольких подписей на один наблюдаемый. Но если я манипулирую наблюдаемым после использования share (), первая подписка будет мертвой. Это небольшой пример […]

RxJava split one Наблюдается до двух subObservables

Я совершенно не RxJava с RxJava и я всю жизнь это понимал, я связываюсь с тем, чтобы решить, как решить эту проблему: У меня есть один объект, полученный с помощью Retrofit , он содержит два ArrayLists , мне приходится обрабатывать каждый ArrayList по-разному. В настоящее время это выглядит так: apiService.getUser(token).enqueue(new Callback<User>() { @Override public void […]

Как я могу запустить это утверждение с помощью RxJava?

Rx способ делать вещи может быть очень сложным ни для кого и по многим причинам … но я чувствую, что есть простые способы делать простые вещи с помощью RX … Как я могу просто выполнить это утверждение в фоновом потоке и получить ответ на поток ui? Все функции этого объекта должны выполняться в фоновом потоке. […]

RxJava для Android: Expose Exception и Retry (с задержкой)

У меня есть следующее Observable, которое будет выполнять REST-Call с доработкой каждые 30 секунд: Subscription subscription = Observable.interval(0, REFRESH_INTERVAL, TimeUnit.SECONDS) .concatMap(new Func1<Long, Observable<Response>>() { @Override public Observable<Response> call(Long time) { return webservice.callRetrofitServiceWithRx(parameter); } }) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new UpdateSuccessAction(), new UpdateErrorAction()); Может случиться, что (особенно REST-Call) вызовет исключение (например, подключение к Интернету). То, что я хотел […]

RxJava + Дооснащение + опрос

У меня есть запрос на доработку и вы хотите вызвать его каждые 30 секунд. Для этого я использую Observable.interval(0, 30, TimeUnit.SECONDS) Observable .interval(0, 30, TimeUnit.SECONDS) .flatMap(x -> RestApi.instance().getUsers()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(list -> { // … }, error -> Timber.e(error, "can't load users")); Моя проблема: если вызов api завершается неудачно, onError и подписка не подписывается, и опрос […]

RxJava как шина событий в проекте Android – удалить событие из шины

Раньше я работал с EventBus, который был прост в использовании и понятен. На этот раз, однако, я хотел бы попробовать RxJava для обмена сообщениями с шиной событий, однако не совсем понятно, как удалить события из RxJava или, лучше сказать, как правильно спроектировать, чтобы иметь подобное поведение, как EventBus Когда я вызываю removeStickyEvent ? В RxJava […]

RxJava – как вызвать подписчика на событиях с 4 кликами в Android

В android у меня есть текстовое представление, определенное следующим образом: <TextView android:id="@+id/text1" android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="@string/hello_world" android:textColorHighlight="#000000" android:textIsSelectable="true" /> Моя цель состоит в том, что после нажатия 4 раза, я хочу начать новую деятельность. Мне нужно сделать это с помощью RXJava; Это требование. Или rxAndroid , rxBinding и т. Д. Моя деятельность выглядит так: public class […]

Intereting Posts
Приложение с надстройкой для навигационной панели в Lollipop Как сделать подписанную и запутанную сборку релиза Android из внутреннего затмения? Исключение android.content.res.Resources $ NotFoundException: файл res / drawable / my.xml из идентификатора ресурса с ресурсом Извлечение данных из базы данных Firebase Realtime в Android Объявить внутреннюю активность в манифесте Android Переход на Android ICS от Fade In / Out назад к слайду Android Fragment Animation onResume Реализация Android Java Minimax в игре tic-tac-toe Данные Exif TAG_ORIENTATION всегда 0 Как отобразить курсор в конце текста в TextView? Запрос Robospice никогда не заканчивается, если приложение идет в фоновом режиме, а затем подходит к Foreground? Удалять фоновые рисунки программно в Android Espresso 2.0 – метод, аннотированный с помощью класса @Test внутри класса, расширяющего тестовую таблицу junit3 Передача пользовательского класса в фрагмент Ищите хороший пример использования get () с AsyncTask в android