Articles of rx android

Как исправить элементы из списка с задержкой в ​​RxJava?

Я использую Retrofit, чтобы получить закладки из REST API: public interface BookmarkService { @GET("/bookmarks") Observable<List<Bookmark>> bookmarks(); } Теперь я хотел бы выпустить каждый элемент из этого списка с задержкой. Я сделал что-то подобное в Java, но onCompleted никогда не запускается. private Observable<Bookmark> getBookmarks() { return getBookmarkService().bookmarks() .flatMap(new Func1<List<Bookmark>, Observable<Bookmark>>() { @Override public Observable<Bookmark> call(List<Bookmark> bookmarks) […]

Как реализовать WebSocket с помощью Retrofit + RX

У меня есть структура проекта, которая использует Retrofit с Rx. Я хотел бы использовать его, чтобы реализовать также связь WebSocket, любую идею, как я могу это сделать?

Android управляет несколькими запросами rxJava на устройстве вращения

Я использую MVVM для Android-приложения, и я хочу управлять запросами и rxJava при вращении устройства, как я могу отключить запрос после поворотного устройства и countinue из последнего запроса? Это мой простой код, чтобы знать, как я могу это сделать, но я не могу найти какой-либо документ и образец кода об этом @Override public void onCreate(@Nullable […]

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

Мне было интересно узнать, как лучше всего реагировать на щелчок элемента просмотра ресайклера. Обычно я добавлял слушателя onclick () в ViewHolder и передавал результаты активности / фрагменту через интерфейс. Я думал о добавлении Observable в onBindViewHolder, но я не хочу создавать новый Observable для каждой привязки элемента.

Как использовать Flowable в RxJava 2?

В RxJava2 появилось новое Flowable. Как использовать это в android. В RxJava1 не было Flowable.

Почему debounce () с toList () не работает в RxAndroid?

Хотя я использую debounce() , затем извлекаю данные из бэкэнд и данные, которые я хочу преобразовать в другие данные, и, наконец, использую toList() . Когда я использую toList() ничего не происходит ни один журнал не в подписке и ошибке, без toList() он работает, и метод subscribe() вводит столько же, сколько у меня есть список книг, […]

RxJava / RxBinding: как обрабатывать ошибки в RxView

Я использую RxJava и RxBindings для просмотра в android. Ниже приведен пример того, что я делаю. RxView.clicks(btMyButton).flatMap(btn -> { // another observable which can throw onError. return Observable.error(null); }).subscribe(object -> { Log.d("CLICK", "button clicked"); }, error -> { Log.d("CLICK", "ERROR"); }); Когда я нажимаю на MyButton, я использую flatMap для возврата другого наблюдаемого, который является […]

RxJava flatMapIterable с одним

Я пытаюсь немного убрать свой код, и « Single выглядит для меня хорошим выбором, поскольку я делаю то, что только когда-нибудь испустит один результат. У меня возникла проблема, поскольку раньше я использовал flatMapIterable для ответа (список) и делал что-то по каждому элементу. Я не вижу, как я могу добиться этого с помощью Single. getListOfItems() .flatMapIterable(items […]

Функция отладки 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 (это принятый термин?) Два наблюдаемых, было бы назвать следующее наблюдаемое в подписчике сразу после обновления пользовательского интерфейса, но я чувствую, […]