Описание тега rx-kotlin2

Описание тега Вопросы с тегом
RxKotlin 2 - это библиотека, которая добавляет в RxJava удобные функции расширения.
1 ответ

RxObservable, который повторяется, пока не будет найдено ожидаемое значение

Цель этой функции - создать поток, который периодически генерирует значения, пока не встретит поток, соответствующий предикату. Вот некоторый скелетный код, который я придумал: class Watcher<T : Any>( /** * Emits the data associated with the p…
17 май '18 в 22:52
1 ответ

Как молча пропустить исключения в RxJava2?

У меня есть поток данных, как это: Observable .fromFuture( CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>> listOf(1, 2, 3, 57005, 5) }, Schedulers.computation() ) .flatMap { it.toObservable() } // I turn t…
24 авг '17 в 23:43
1 ответ

RxKotlin зависит от RxJava в Android?

Можно ли использовать Rx Kotlin + Rx Android без добавления Rx Java? Или Rx Kotlin зависит от Rx Java.
27 мар '18 в 23:47
2 ответа

Одна наблюдаемая должна излучать предметы на основе других наблюдаемых излучаемых предметов, и обе наблюдаемые не связаны

У меня есть две разные наблюдаемые, которые ведут себя как Поведение Observable one -> Это будет создано, и один DisposableObserver будет подписан на него и реагирует на элементы, испускаемые Observable One. Это будет работать непрерывно, пока прило…
16 янв '19 в 21:45
2 ответа

Лямбда игнорируются до тех пор, пока не будет добавлено "run"

У меня есть цепочка RX, которая вызывает API через Retrofit. Я подписываюсь на мой сервис API со стандартным rx subscribe({...}) метод и передать лямбду к нему. К сожалению, когда мой вызов, наконец, завершен, весь код, который я добавил для выполне…
11 мар '18 в 00:51
2 ответа

RxJava 2 mock Observable не работает

Я использую RxJava 2 Observable обернуть сканер штрих-кода в одном из моих приложений. Этот фрагмент показывает, как я подписываюсь на Observable и слушать его события override fun start() { disposables.addAll(subscribeToBarcodeReader(), loadUser())…
06 апр '18 в 05:20
1 ответ

Как связать Observable с Синглом в RxJava?

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

Реализовать разделяемый Flowable в RxKotlin с динамическими параметрами

Ничто из того, что я пробовал, похоже, не решило мою проблему. У меня есть три кнопки с поведением onClick. Каждая из этих кнопок вызывает один и тот же метод launchActivity но с разными параметрами. launchActivity делает IO с переменными, полученны…
06 май '18 в 20:08
1 ответ

Объединяйте два предмета только тогда, когда один из них меняется, а последние получают от другого

Я застрял, получая следующий пример, работающий как ожидалось, я попытался использовать zip а также combineLatest и как показано ниже withLatestFrom однако ни один из них не дает ожидаемого результата. @Test fun thereCanBeOnlyOne() { val s1 = Behavi…
19 ноя '17 в 12:28
1 ответ

Оператор share() не работает для Observable в Rxjava

У меня есть сценарий, где у меня есть эмиттер, который постоянно излучает данные, как это fun subscribeForEvents(): Flowable<InkChannel> { return Flowable.create<InkChannel>({ if (inkDevice.availableDeviceServices.contains(DeviceServiceT…
24 ноя '18 в 08:23
1 ответ

Цикл For с RxJava2 или RxKotlin

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

Replay(1) не работает внутри публикации

val subject = PublishSubject.create<UiModel>() val pipeline = subject .compose({ val models = it.ofType(UiModel.Model::class.java) .replay(1) .autoConnect() val navigation = it.ofType(UiModel.Navigation::class.java) Observable.merge(models, n…
05 июл '18 в 13:34
1 ответ

Компиляция сборки Gradle для репозитория RxKotlin завершается неудачно с Gradle 4.7 (JDK 1.8)

Я попробовал следующее: $ git clone https://github.com/ReactiveX/RxKotlin.git $ cd RxKotlin/ $ gradle build Это терпит неудачу с: ... FAILURE: сборка не удалась, исключение. Где: строка файла сборки /home/myuser/RxKotlin/build.gradle: 13 Что пошло н…
27 июн '18 в 23:49
0 ответов

RxJava2 и Kotlin: OnErrorNotImplementedException

Я использую RxJava2 с Kotlin. Я не знаю почему, но у меня всегда есть эта ошибка: io.reactivex.exceptions.OnErrorNotImplementedException: операция не реализована: не реализована Поэтому я добавляю своему подписчику обратный вызов onError, но теперь …
15 май '18 в 20:46
2 ответа

Как мы можем буферизовать элементы в каждую миллисекунду и передавать каждый элемент через постоянный интервал времени

Метод onNext publishSubject вызывается непрерывно (в неравное время, приблизительно за 1 миллисекунду). Требуется, чтобы эти элементы передавались каждую 1 секунду, и данные не должны быть потеряны, значит, каждый элемент должен излучать. publishSub…
11 янв '19 в 14:08
0 ответов

Сбрасываемый паттерн Single Rx

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

Наблюдаемый withLatestFrom не срабатывает при использовании с Observable.just(1)

withLatestFrom не стреляет при использовании с Observable.just(1) как показано ниже. Как будто это зашло в тупик. rxPositionCapability.position является Observable<Position> это очень часто обновляется в вычислительном потоке. это setPositionP…
28 окт '18 в 16:03
2 ответа

Повторное использование части потока RxJava

Вероятно, это вопрос rx newbee. Если у меня есть два потока RX, которые имеют некоторые общие части, есть ли возможность извлечь и использовать их повторно? Вот пример псевдокода: someManager.getInfo(id) returns a Single<SometInfo> Это веселье…
04 окт '18 в 08:39
1 ответ

RxJava2: onComplete не вызывается с flatMapIterable

Вот короткий фрагмент кода: val subject = BehaviorSubject.createDefault(emptyList<Int>()) subject.onNext(Arrays.asList(1, 2, 3)) subject.flatMapIterable { list: List<Int> -> list } .subscribeBy( onNext = { l("on next", it) }, onComple…
05 окт '17 в 15:47
1 ответ

RxJava2 onNext() вызывается несколько раз?

У меня есть метод, который возвращает Observable, как это: open fun get(): Observable<Response> { return if (condition) getDataFromApi() else getDataFromDb() } и подписывается следующим образом: get() .subscribeOn(Schedulers.io()) .observeOn(A…
11 июл '18 в 08:28