У меня есть операция цепочки в моем приложении, где у меня есть список некоторых данных, я буду перебирать список с iteratable observable после завершения итерации, я выполню другую операцию, которая не зависит от предыдущего списка, так что мне...

Я новичок в мире Rx, поэтому, пожалуйста, потерпите меня. Мой код на Kotlin, но код Java также поможет. У меня есть 2 метода, один из них загружает задачи из базы, если есть задачи, я хочу отправить их на сервер. fun getListFromDb():...

У меня есть следующий дизайн, который я хотел бы создать, но я не уверен, какой шаблон Rx ему соответствует. Цель более-менее похожа на сингл, но с условной проверкой. Есть один Observable<String> , и возможно любое количество...

Этот вопрос связан с Android и жизненными циклами. Раньше я бы завел серию тем и подписался бы на них при создании. После уничтожения я бы пометил все предметы как завершенные, предполагая, что он избавляется от всех подписчиков. В Android...

Я пытаюсь написать функцию преобразования, которая используется с compose() , чтобы сократить шаблонный код. Это довольно просто: fun <R> withSchedulers(): ObservableTransformer<R, R> { return ObservableTransformer {...

Когда я пытался обновить свою Android Studio до версии 3.4, обновление не проходит гладко, некоторые зависимости ломаются. В моем случае зависимости RxJava/RxKotlin ломаются без каких-либо подсказок. Даже это происходит случайным образом, поскольку...

Мне нужно, чтобы я вызывал завершаемый метод в цепочке, после того, как он завершится, он должен продолжить цепочку с помощью оператора Map Пример Single.just(someOperation()) .flatMapCompletable{ completableMethod() }...

У меня есть этот код Android Kotlin со списком комплементов, которые объединены в более крупный с mergeDelayError() , у которого есть тайм-аут. По истечении времени ожидания я получаю java.util.concurrent.TimeoutException: The source did not signal...

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

Я хочу создать асинхронную операцию, которая повторяет символы в заданной строке. У меня есть массив символов, взятый "mystring".toCharArray() . Я хочу повторить каждый 10-й символ с помощью RX. Я знаю, что могу сделать это с помощью AsyncTask...