Вопросы по теме 'rx-kotlin'
RxJava (Kotlin), Observable.amb и PublishSubject не запускаются
Мы пытаемся соблюдать либо 15-секундный интервал, либо каждый раз, когда мы стреляем onNext по нашему объекту refreshEventsSubject , но безуспешно.
Тема инициирована так
private val refreshEventsSubject = PublishSubject<Long>()
А...
1465 просмотров
schedule
10.10.2021
Каков вариант использования doOnSuccess против onSuccess в rxJava
Я не понимаю, как использовать doOnSuccess в rxJava. Давайте посмотрим на код:
Дело 1:
networkApi.callSomething()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnSuccess(__ ->...
9218 просмотров
schedule
17.11.2021
Как я могу использовать результат ответа вызова RXJava в качестве условия для оператора if внутри другой функции RXJava?
Я делаю 2 вызова RX, которые вложены друг в друга и зависят друг от друга. Существует проблема с сервером (который не может быть решен прямо сейчас по разным причинам), который возвращает ошибки во втором вложенном вызове.
Пока это не будет...
73 просмотров
schedule
11.11.2021
сопоставление пользовательских данных RxAndroid с Kotlin
Я пытаюсь преобразовать примеры из этой статьи с Явы на Котлин. Я получаю сообщение об ошибке на изображении на Exmaple 5:
И я заметил, что без функции map () я не получаю эту ошибку
Итак, в чем смысл этой ошибки и как ее...
75 просмотров
schedule
21.02.2022
Объединить результат трех API в RxKotlin
У меня есть функция в репозитории, которая вызывает три API, которые возвращают три разных типа объектов.
fun scanSource(code: String) =
firstApi.DataV11Get(code)
.flatMap {
firstApi.sccGet(it.sscc)
}...
101 просмотров
schedule
01.08.2022
Как связать Observable с Single в RxJava?
Я новичок в мире Rx, поэтому, пожалуйста, потерпите меня.
Мой код на Kotlin, но код Java также поможет.
У меня есть 2 метода, один из них загружает задачи из базы, если есть задачи, я хочу отправить их на сервер.
fun getListFromDb():...
2249 просмотров
schedule
11.08.2022
Как сделать оператор фильтра из списка списка в rxjava
Добрый день. Итак, у меня есть список со списком внутри вроде этого:
{
"category" : [
{
"name": "Bathroom",
"products": [
{
"name": "Sink01"
},
{
"name": "Shower01"
}...
59 просмотров
schedule
20.08.2022
Использование диапазона в zipWith также выдает все элементы из последовательности диапазона до применения функции застежки-молнии.
Вопрос про RxJava2.
Заметил, что при сжатии Throwable из retryWhen с помощью range выбрасываются все элементы из Observable.range до того, как была применена функция застегивания. Кроме того, range выдает последовательность, даже если...
284 просмотров
schedule
07.09.2022
Как поместить заголовок в URL-адрес, используя залп в Котлине?
Мой код-
val accessTokenRequest: JsonObjectRequest = JsonObjectRequest(Request.Method.GET, url,
Response.Listener { response ->
},
Response.ErrorListener { error ->...
2770 просмотров
schedule
21.09.2022
RxJava 2 эквивалентен isUnsubscribed
Я работал с примерами в книге Observable<BigInteger> naturalNumbers = Observable.create(subscriber -> {
Runnabler = () -> {
BigInteger i = ZERO;
while (!subscriber.isUnsubscribed()) {...
912 просмотров
schedule
02.11.2022
Реализация клапана для наблюдаемых потоков, включая буферизацию последнего элемента, испускаемого перед повторным открытием клапана.
Я пытаюсь понять, как реализовать что-то в RxJava (2.0). Это для Android, и я использую Kotlin, хотя выбор платформы и языка здесь не должен иметь значения.
Идея состоит в том, что я бы основал какую-то архитектуру MVP на RxJava. В этой...
466 просмотров
schedule
15.07.2023
Как я могу условно добавить асинхронную операцию в середине потока RxJava?
Вот упрощенная версия того, что я пытаюсь сделать (используя Kotlin и RxJava)
makeServerCall()
.doOnNext {
doStuff(it)
}
//TODO: if it == 0, call asyncOperation() and wait for its...
307 просмотров
schedule
22.11.2022
RxKotlin — динамический массив наблюдателей
Я использую RxKotlin вместе с Retrofit 2.
Я пытаюсь понять, как иметь динамический список наблюдателей за одну операцию.
Первый наблюдатель должен инициировать операцию, а все дополнительные наблюдатели должны дождаться завершения или сбоя...
470 просмотров
schedule
09.06.2023
RXKotlin Lambda Понимание
Это никогда не завершается:
Completable.complete()
.andThen{ Completable.complete() }
.test()
.assertComplete()
Это завершает:
Completable.complete()
.andThen(Completable.complete())
.test()...
310 просмотров
schedule
10.09.2023
Список не выдается при удалении элемента (RxKotlin)
Я работаю над приложением для Android. У меня есть список фотографий, загруженных в память. Я хочу использовать библиотеку Reactive, поэтому я объявляю источник данных в памяти, где я сохраняю список:
@Singleton
class MemoryPhotosSource...
67 просмотров
schedule
25.06.2023
RxJava: concatMap() с zip() зависает
У меня есть фиктивный сетевой источник данных:
fun networkDataSource(): Single<List<Int>> {
return Single.just((0 until 100).toList())
.delay(150, TimeUnit.MILLISECONDS)
}
Вот бесконечная...
744 просмотров
schedule
15.03.2023
Выполните задачу для всех элементов в списке, а затем выполните другую задачу в RxJava.
К сожалению, моя операция REST Delete работает только для одного элемента. Итак, что я пытался сделать, это,
Observable.just(items).flatMapIterable { items -> items }.flatMap {
//call REST DELETE for every item...
252 просмотров
schedule
14.06.2023
Rxjava - Как получить текущий и предыдущий элемент?
Как использовать операторы, чтобы всегда получать предыдущее и текущее значение? Если возможно, я хочу избежать создания состояния за пределами трубы.
- time ->
1 2 3 4
| | | |
Operations
| | |...
196 просмотров
schedule
17.07.2023
Как выполнить операцию на основе нескольких результатов RxJava Completable
Некоторое время я ломал голову над этим, я потерялся здесь в управлении требованием, когда я должен использовать Rx в Котлине.
Позволь мне объяснить.
Существует набор идентификаторов, эквивалентные элементы которых должны быть удалены с сервера и,...
77 просмотров
schedule
12.03.2023
Rx, как вернуть Throwable или Object в зависимости от типа ошибки
У меня есть метод, который возвращает Observable. У меня есть случай, когда в случае ошибки мне нужно проверить тип ошибки, а для какой-то конкретной ошибки мне нужно вернуть MyObject вместо ошибки.
Пример:
override fun getSomething(param:...
39 просмотров
schedule
12.12.2022
