rx-java

2зной

1ответ

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

Я новичок в RxJava (в частности, RxJava2), и у меня возникают некоторые проблемы с тем, что кажется относительно простой операцией. Мне нужно получить некоторые данные из db, выполнить итерацию данных

0зной

1ответ

Vertx Создание нескольких вертикальных экземпляров, прослушивающих один и тот же сокет

Я разрабатываю сервер датаграмм, который прослушивает сообщения на конкретном порту, и мы используем Vertx Java Framework для его реализации. Все работает нормально, если я укажу только один экземпляр

0зной

1ответ

retryWhen с таймером появляется ниспровергать поведение на Merge

Я использую RxJava в асинхронной передачи сообщений среде (vert.x), и поэтому имеют поток, который выглядит следующим образом: Observable.defer(() -> getEndpoint()) .mergeWith(getCancellationMe

1зной

1ответ

RxJava: не работает

У меня возникли некоторые проблемы в модульном тесте, которые я кодирую с помощью Robolectric. Дело в том, что я тестирую UseCase, этот UseCase использует rx.Observable для выполнения асинхронной зада

5зной

4ответ

Immediate debounce in Rx

Я ищу оператора для debounce серию событий, скажем, щелчок пользователя. Ввод и вывод должен быть такой: interval : -> <- -> <- in : 1--2--3-------4--5--5--6-7-8-------- out : 1-------------4

-1зной

2ответ

Несколько вызовов api для Android с использованием RxJava

У меня есть список объектов, которые отправляются как тело для запроса по почте в каждом вызове api. Все запросы на отправку должны выполняться параллельно. Для каждого запроса он должен уведомить об

11зной

5ответ

Как разрешать повторяющиеся файлы, скопированные в APK META-INF/rxjava.properties

Я использую rxjava и rxvolley на моем андроиде. Когда я пытаюсь запустить его, я получаю эту ошибку Execution failed for task ':testapp:transformResourcesWithMergeJavaResForDebug'. > com.android.buil

2зной

1ответ

Как освободить последний элемент ussing takeWhile?

У меня есть поток, который испускает элементы с момента создания элемента. Я знаю, какой элемент. После того как этот элемент будет включен, поток больше не выделяется. Проблема в том, что он не выпус

9зной

2ответ

Rx 2 Android, что лучше Single или Observable для звонков api?

, когда мы используем retrofit2 для выполнения вызовов в режиме API с помощью Rx. Каков наилучший подход к использованию, Single или Observable? public interface ApiService{ Single<Data> getDataFrom