Articles of rx java

Начало работы с RxJava с помощью sqlite

Я участвую в процессе обучения RxJava и прошел несколько статей и видео. Я полностью ощутил, что RxJava может предложить, поэтому я думаю, что в настоящее время я понял, что такое реактивное программирование. Этот урок Дэн Лью помог мне немного понять основы использования RxJava. Но я узнал, что чем больше я думал, что полностью понял RxJava, […]

Неустранимая исключение, брошенное на Scheduler.Worker thread с Retrofit 2 и Rx

Это код, который я использую для вызова Http. Я не могу воспроизвести ошибку, но Bugsnag сообщает мне, что некоторые пользователи получают эту ошибку: java.lang.IllegalStateException StrictMode.java public class ApiManager { public interface Callback<T> { void onError(Throwable e); void onSuccess(T result); } private ApiService _apiService; public ApiManager() { Retrofit retrofit = new Retrofit.Builder() .baseUrl(BuildConfig.BASE_URL) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .addConverterFactory(GsonConverterFactory.create()) .client(ew […]

Ошибка переоснащения 2 + Rxjava

Так что я уже получаю токен от Json, когда логин сделан без проблем и получает хэш Но когда ответ с сервера является ошибкой, я не могу получить сообщение Json ({message: «Ошибка: неправильное письмо»), потому что в onError мы получаем только аргумент Throwable, а не класс модели, например, в Как я могу получить сообщение json с […]

RxJava как шина событий, onNext вызывается несколько раз, когда только одно сообщение о событии

Я реализую шину событий (RxBus) с RxJava. RxBus.java public class RxBus { private static final String TAG = LogUtils.makeTag(RxBus.class); private static final RxBus INSTANCE = new RxBus(); private final Subject<Object, Object> mBusSubject = new SerializedSubject<>(PublishSubject.create()); public static RxBus getInstance() { return INSTANCE; } public <T> Subscription register(final Class<T> eventClass, Action1<T> onNext) { return mBusSubject .filter(new […]

Observable.just (), который возвращает Единицу в Котлин

У меня есть часть Observable, которая, в конце концов, возвращает ошибку и повторяет попытку или просто возвращает onNext. Мне не нужно ничего в onNext, так что это всего лишь Observable<Unit> . Теперь проблема в том, что в конце цепочки я должен ударить это по следующему, и у меня нет ничего, кроме старого старого Observable.just() . […]

RxJava + retrofit, получить список и добавить дополнительную информацию для каждого элемента

Я играю с RXJava, обновляюсь в Android. Я пытаюсь выполнить следующее: Мне нужно периодически опросить вызов, который даст мне Observable> (Отсюда я мог бы это сделать) Как только я получу этот список, я хочу перебирать каждую доставку и вызывать другие методы, которые дадут мне ETA (так что просто больше информации). Я хочу прикрепить эту новую […]

RXJava – запуск нескольких наблюдаемых за другим (например, concat, но с onCompleted для каждого наблюдаемого)

Есть ли способ достичь следующего: У меня есть 3 наблюдаемых типа Observable<MyData> . Я хочу: Запустить первый наблюдаемый Соблюдайте onCompleted первого наблюдаемого Запустить второй наблюдаемый Соблюдайте onCompleted второго наблюдаемого Запустить третий наблюдаемый Соблюдать onCompleted третьего наблюдаемого Это можно сделать с помощью concat но тогда я только смогу наблюдать за последним onCompleted . Уродливое решение Я […]

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

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

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

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

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

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