Articles of rx java2

Как объединить 2 отдельных потока, буферизовать заполненные данные из них и subsrcibe к нему после некоторого времени

Я пытаюсь проверить ситуацию следующим образом: У меня есть 2 класса, которые просто простираются от одного и того же Родительского. Я создаю и Observables из списка элементов для каждого класса: val listSomeClass1 = ArrayList<SomeClass1>() val listSomeClass2 = ArrayList<SomeClass2>() fun populateJust1() { listSomeClass1.add(SomeClass1("23", 23)) listSomeClass1.add(SomeClass1("24", 24)) listSomeClass1.add(SomeClass1("25", 25)) } fun populateJust2() { listSomeClass2.add(SomeClass2(23.00)) listSomeClass2.add(SomeClass2(24.00)) listSomeClass2.add(SomeClass2(25.00)) } […]

Цепочка ошибок Завершение после flatMapCompletable

Для каждого Event , мне нужно отправить его и проверить его. У меня есть этот код: fun process(): Completable = eventsDao.findAll() .flatMapCompletable(this::sendEventToServer) .andThen(this::validate) //Error here fun send(event: Event): Completable = //code fun validate(event: Event): Completable = //code Ошибка: (14, 18) Ни одна из следующих функций не может быть вызвана с предоставленными аргументами: @CheckReturnValue @SchedulerSupport public […]

Как вы используете Flowable.generate от Kotlin

Вот неудачная попытка заглушки в Flowable.generate (с большим количеством аннотаций типа, чем я обычно использовал): val xs: Flowable<String> = Flowable.generate<Int, String>( java.util.concurrent.Callable<Int> { -> 0 }, io.reactivex.functions.BiConsumer<Int, String> { t1, t2 -> } ) Ячейку Java, которую я хотел бы использовать, это: public static <T, S> Flowable<T> generate(Callable<S> initialState, final BiConsumer<S, Emitter<T>> generator) Ошибка, которую […]

Ошибка Observable.combineLatest после обновления до RxJava 2.xx – не может выводиться тип

В последние несколько дней я пытаюсь перенести свой проект с RxJava 1.xx на RxJava 2.xx У меня есть этот простой метод. Все нормально, если я использую Observables из rxjava 1.xx (rx.Observable). Однако, когда я заменил его «новыми» наблюдаемыми (io.reactivex.Observable, я получаю сообщение об ошибке: «Ошибка ввода типа. Пожалуйста, fun <T1, T2, T3, R> combineLatestValue3Nullable(observable1: Observable<T1?>, […]

Как издеваться над реактивным репозиторием, который возвращает Observable

Поэтому у меня есть репозиторий, который предоставляет наблюдаемому клиенту. Есть ли способ, которым я могу издеваться над этим репозиторием, поэтому мне не нужно отправлять местоположение из моего эмулятора или использовать реальное устройство, чтобы получить какое-то местоположение? Вот как выглядит интерфейс: interface RxLocationRepository { @SuppressLint("MissingPermission") fun onLocationUpdate(): Observable<Location> fun stopLocationUpdates() } В моей стороне клиента я […]

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

У меня есть две несортированные наблюдаемые разные типы. Оба эти типа имеют общий ключ. Я хотел бы объединить их в новые наблюдаемые излучающие пары соответствующих элементов, и я не могу понять, как это сделать. Обратите внимание, что некоторые из ключей могут отсутствовать. Было бы хорошо, если бы не полные пары были сброшены, но отсутствие null […]

FATAL EXCEPTION: RxCachedThreadScheduler-1 при запуске триггера. Зачем?

У меня есть следующий код RxJava 2 (в Котлине), у которого есть наблюдаемый disposable = Observable.create<String>({ subscriber -> try { Thread.sleep(2000) subscriber.onNext("Test") subscriber.onComplete() } catch (exception: Exception) { subscriber.onError(exception) } }).subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe({ result -> Log.d("Test", "Completed $result") }, { error -> Log.e("Test", "Completed ${error.message}") }) Хотя он по-прежнему является Thread.sleep(2000) , я выполняю disposable?.dispose() […]

RxJava2 наблюдаемый не обрабатывается вNext при изменении

Я новичок в RxJava. Я хочу отслеживать изменения переменной Int и реагировать на нее, когда она изменяется. Вот мой пример: class MainActivity : AppCompatActivity() { lateinit var button: Button var counter: Int = 0 override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) val observable :Observable<Int> = Observable.just(counter) button = findViewById(R.id.button) button.setOnClickListener(View.OnClickListener { counter++ }) observable.subscribe( Consumer […]

Изменение наблюдаемого при условии met – RxJava2

Используя RxJava2 RxKotlin и Room , мне нужно запросить базу данных для открытой охоты. Это означает, что я ищу охоту, содержащую атрибут, closed со значением false . Как только охота найдена, необходимо переключить запрос на эту конкретную охоту. У меня есть 2 метода для этих запросов: getOpenHunt(teamId:String): Flowable<List<Hunt>> getHunt(huntId:String): Flowable<List<Hunt>> Они оба возвращают List потому […]

Retrofit-Vertx с RxJava2 в Kotlin IllegalStateException message == null

Я создаю очень простое приложение в Kotlin с Vertx и RxJava 2 (RxKotlin), используя Kovert REST framework и Retrofit. У меня есть адаптер retrofit-vertx и адаптер RxJava2 Retrofit. Я могу вернуть произвольный список из моего listUndergroundStations() , но всякий раз, когда я пытаюсь загрузить из удаленного API, я получаю следующую ошибку: Jun 23, 2017 2:16:29 […]

Intereting Posts
Какое правильное название для встроенной документации Kotlin? Есть ли способ сортировки ключей groupBy в rx-java / kotlin? Запустите Kotlin REPL из контекста моего проекта Maven? Возможно ли, чтобы Java создала перегрузку метода с аргументами по умолчанию, такими как Kotlin? Получение сигнала Fata 11 при попытке использования Observable Недостаток равенства Котлина Ошибка: Kotlin: несколько значений недопустимы для опции плагина. Org.jetbrains.kotlin.kapt: output Kotlin: Невозможно применить сразу два условных выражения с помощью стиля функции «возврат тела» Создайте общий 2D-массив в Котлине Реагировать на перестройку вызова RxJava запускает часть плана в основной теме Как позвонить по номеру телефона в Kotlin Android Ошибка раздувания фрагмента класса android kotlin Параметр принудительного типа должен быть инвариантным на сайте-участнике, когда он является ковариантным на сайте объявления Тип функции Kotlin вместо функционального интерфейса лямбда