Articles of rx java

Что вызывает HTTP FAILED: java.net.SocketException: Socket закрыт?

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

Создание N последовательных вызовов api с использованием RxJava и дооснащения

У меня есть список файлов, которые я бы хотел загрузить на сервер с устройства Android. Из-за ограничений памяти я хотел бы сделать второй вызов API только после первого завершения, третьего после второго завершения и так далее. Я написал что-то вроде private Observable<Integer> uploadFiles(List<File> files) { return Observable.create(subscriber -> { for (int i = 0, size […]

Царство закрывается

Я использую один статический глобальный экземпляр Realm (никогда не закрытый) для объекта Application только для использования в потоке пользовательского интерфейса, @UiThread public static Realm getRealm() { if (Thread.currentThread() == Looper.getMainLooper().getThread()) { return realmInstance; } else { Timber.e("Illegal access to getRealmObservable"); throw new IllegalStateException("Only UI Thread can access this realm"); } } И другое единственное место […]

Как отменить модифицированный реактивный запрос в java?

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

Очередь фоновых задач в rxjava

Можно ли реализовать очередь фоновых задач с помощью rxjava? Мне нужно добавить задачу в любое время и выполнить только одну задачу одновременно. Я попробовал PublishSubject , но когда я PublishSubject выполнение на новый поток observeOn(Schedulers.newThread()) он запускает более одной задачи вовремя. UPDATE: возможно ли реализовать что-то вроде шаблона производителя-потребителя с помощью rxjava?

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 Поэтому […]

RxJava как шина событий?

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

Как создать 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) […]

Сочетание слушателя данных Firebase в реальном времени с RxJava

Я использую Firebase в своем приложении вместе с RxJava. Firebase может уведомлять ваше приложение, когда что-то изменилось во внутренних файлах (добавление, удаление, изменения, …). Я пытаюсь объединить функцию Firebase с RxJava. Данные, которые я слушаю, называется Leisure , а Observable испускает LeisureUpdate который содержит Leisure и тип обновления (добавление, удаление, перемещение, изменение). Вот мой метод, […]

Kotlin: Что означает «return @»?

Я использую RxJava в одном из моих проектов, я преобразовал один из своих классов в Kotlin, используя плагин Android Studio, и в одной из карт lambda (Func1 в java) mapMedia1, промежуточные результаты выглядят следующим образом @Func1 . Я без понятия что это значит. something.flatMap(Func1<ArticleCriteria, Observable<Pair<String, String>>> { val isTemporaryClone = it.isATemporaryClone val isTheOriginalToken = it.tokenIsOriginalHere […]