Описание тега rx-android

Описание тега Вопросы с тегом
Привязки RxJava для Android
2 ответа

RxJava заставляет retryWhen() запускать метод onError()

У меня есть следующий класс с реализацией RxJava для загрузки двух ресурсов из API. Я делаю некоторые rx, чтобы позволить ему повторить или повторить, если он не отвечает требованиям API / соединения. Тем не менее, я не могу заставить retryWhen() за…
30 сен '16 в 07:31
1 ответ

Проверьте сетевое соединение в Observable перед выполнением вызовов API

Я пытаюсь использовать следующую функцию для проверки сетевого подключения private boolean isThereInternetConnection() { boolean isConnected; ConnectivityManager connectivityManager = (ConnectivityManager) this.context.getSystemService(Context.CONNE…
17 ноя '15 в 14:09
1 ответ

Как вы делаете продолжения с RxJava Observables?

Итак, у меня есть одна асинхронная операция A это зависит от секунды, B, Как сделать B продолжением A, как это было бы с тогдашней функцией Javascript Promises или с ContinueWith в.NET TPL? Давайте возьмем сценарий с Android, где у меня есть две кон…
24 ноя '14 в 14:22
1 ответ

Ожидание пары наблюдаемых, чтобы закончить с / без последовательности Retrofit2 с rxjava - Android

Я использую модификацию 2 с расширением rxjava У меня есть 3 Observables, которые будут делать 3 разные вещи Observable<String> observable1 = RetrofitInterface.GetByID(id); Observable<String> observable2 = RetrofitInterface.GetByKey(key)…
14 июн '16 в 12:26
1 ответ

Как можно условно добавить асинхронную операцию в середине потока RxJava?

Вот упрощенная версия того, что я пытаюсь сделать (используя Kotlin и RxJava) makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the stream. Otherwise i…
14 сен '17 в 16:27
0 ответов

RxAndroid: onCompleted не вызывается

Я использую библиотеки rx в моем приложении, чтобы вызвать REST API на моем сервере и показать результаты на экране. Я также следую шаблону дизайна MVP. Так что у меня есть классы Presenter и Interactor. В MainInteractor.java у меня есть следующий м…
01 фев '18 в 08:09
1 ответ

Не удалось получить ответ от Rxjava Retrofit

Я пытаюсь получить ответ, но не получаю его. Также я не получаю никаких ошибок. что я делаю не так? сделал POJO через jsonscema2Pojo.org может быть, как я звоню @GET("16126940.json") Observable <NewsFeed> getFinalData(); в сервисе это неправил…
12 янв '18 в 16:31
1 ответ

RxJava2 Flowable.combine Последнее поведение, если все Flowables не излучают

Я следую этому коду, чтобы сделать некоторые проверки ошибок. Ниже приведена реализация CombineLatest, которая принимает входные данные из 3 полей и выполняет проверку ошибок для каждого из них. Flowable.combineLatest( _emailChangeObservable, _passw…
05 июл '17 в 19:14
3 ответа

NPE пока список фильтров с io.reactivex.Observable

Я столкнулся с проблемой, пока пытаюсь отфильтровать ArrayList из String как Observable, Все работает нормально, если: MatrixCursor suggestionsCursor = new MatrixCursor(new String[]{BaseColumns._ID, COLUMN_FIELD_NO}); for (int i = 0; i < data.siz…
10 авг '18 в 09:41
1 ответ

Последовательные сетевые вызовы RxJava

Я хочу сделать два вызова, один для списка репозиториев на github, второй для коммитов на каждом репо, и хочу сохранить их вместе. Во втором вызове мне нужен экземпляр родительского pojo, чтобы я мог добавить к нему ответ потомка. т.е. сохранить: Ги…
12 июн '18 в 06:48
3 ответа

Как вызывать один и тот же API N раз, используя Retrofit и RXJava. На данный момент я использую следующий подход

Хорошо. Итак, документация API гласит: Получите до 100 ресторанов, изменив параметры start и count с максимальным значением count 20. API LINK: https://developers.zomato.com/documentation Это пример кода: restaurantList = new ArrayList<>(); re…
25 окт '17 в 09:51
3 ответа

Как преобразовать массив в наблюдаемый

Как показано в следующем коде, я хотел бы использовать RxAndroid. но я сталкиваюсь с двумя проблемами: 1- Я хочу преобразовать массив в наблюдаемый, но метод.fromArray не распознается 2- Почему в интерфейсе Observer не реализован onSubscribe(Disposa…
17 июл '18 в 10:44
2 ответа

RxJava и rx.exceptions.MissingBackpressureException исключение

Я пытаюсь заставить работать очень простое приложение на основе RxJava. Я определил следующий класс Observable, который читает и возвращает строки из файла: public Observable<String> getObservable() throws IOException { return Observable.creat…
02 янв '16 в 20:53
0 ответов

AndroidSchedulers.mainThread отмечает onError раньше, чем onNext

Сегодня я застрял, как я был в беде о AndroidSchedulers.mainThread() Obervable.create(emitter -> { emitter.onNext(1); emitter.onNext(2); emitter.onNext(3); // Thread.sleep(10); emitter.onError(new RuntimeException("error")); }).subscribeOn(io()) …
16 янв '18 в 16:56
1 ответ

Подписаться и отказаться от подписки на каждый отправленный элемент

Я использую lib реактивной локации. Мой вариант использования состоит в том, что у меня есть поток объектов, излучаемых из наблюдаемой. Эти предметы могут быть выброшены потенциально каждые несколько часов. Как только элемент выпущен, я хочу получит…
22 окт '15 в 19:26
4 ответа

Преобразование чисел в формат валюты при изменении текста

Я использую RxTextView.textChanges за EditText что, когда пользователь печатает изменить значение EditText конвертировать числа в формат валюты, как показано ниже: 1,000 Но я не вижу конвертирования чисел в валюту. Я использую от: NumberFormat.getNu…
05 дек '17 в 08:28
2 ответа

Как использовать интервал rx java для фоновой задачи

Согласно https://github.com/ReactiveX/RxAndroid/issues/257. Интервал только для активного кода, и если приложение не активируется, оно не будет работать. Итак, как использовать интервал для задач фонового планирования?
13 дек '15 в 15:33
1 ответ

Android/RxJava Как связать сетевые запросы и повторить попытку в случае сбоя

Я пытаюсь связать сетевые запросы с помощью RxJava в Android, а затем повторить попытку при сбое. Я просматривал Stackru о том, как сделать это, не попадая в ад Callback, который приходит с использованием одного только Android и Retrofit. Я могу сде…
15 фев '16 в 02:57
3 ответа

Оператор RxJava похож на amb, но только с действительными результатами

Я хочу автоматически найти устройство в Android приложение. Поэтому я хотел бы сделать два звонка, сетевой звонок с Retrofitи не сетевой вызов с использованием специального SDK, в то же время, чтобы выяснить, какое устройство использует пользователь…
17 окт '16 в 13:23
1 ответ

Каков наилучший подход замены AsyncTaskLoader на RxJava2?

Я супер младший в RxJava, и мне нужна помощь, чтобы найти лучший подход, если я выбрал плохой подход или есть лучший способ сделать это. Я работаю над наследством Loader код, и я хочу заменить его на RxJava. В моем исходном коде есть следующее: publ…
30 янв '17 в 21:56