Articles of rx java2

Наблюдаемые трансформаторы из объектов

В настоящее время я реализую шаблон, который имеет круговую зависимость view-viewmodel. Хотя его действительно не зависимость, потому что они не знают друг о друге, все, что они знают, это то, что есть поток событий и поток состояний. Я придумал идею создания viewModel функции, называемой toTransformer() которая возвращает ObservableTransformer , состоящий из двух предметов, объекта события […]

RxJava2 Может быть возвращено пустое Наблюдаемое, если ни один элемент

Есть ли лучший / более идиоматический способ использования типа Maybe из JavaRx 2, чем flatMap и try/catch ? В следующем примере выберете Maybe<User> и попробуем заказать им случайный билет для полета. Если пользователь не существует, верните пустой Observable . fun bookRandomTicketFor(userId: UUID): Observable<Ticket> { val agencies = travelAgents() // Observable<TravelAgency> val user = findById(userId) // […]

RxJava2 как отделить различную реализацию наблюдаемого излучателя

Это моя ситуация. Я хочу разоблачить 2 различные реализации Observable <'Location'> из моего родного LocationManager Android или из сервисов Google. Я хочу проверить, использую ли я родной подход или gms. Поэтому, в конце концов, я хочу разоблачить Observable моему клиенту – ему не нужно знать, с какого подхода я собрал место. Обратите внимание, что я […]

Получение сигнала Fata 11 при попытке использования Observable

Я работаю над проектом, который пытается впервые использовать Kotlin, RxJava 2 и новые компоненты архитектуры Android. Я пытаюсь выполнить метод удаления из комнаты в отдельном потоке, и я получаю ERROR: Fatal signal 11 (SIGSEGV), code 1, fault addr 0x0 in tid 12673 (RxCachedThreadS) при выполнении метода, и сила закрывается. Я пробую эти два варианта: 1. […]

Запрос на Android всегда дает исключение тайм-аута сокета

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

Как подсчитать время выполнения наблюдаемого

Я ищу решение для измерения выполнения какой-либо задачи Я хочу запустить таймер в некотором месте Я хочу выполнить некоторую задачу В другой части кода я хочу, чтобы можно было остановить таймер, я получаю окончательное время выполнения выполнения Я думаю, это может быть очень похоже на использование EventBus для публикации события начала подсчета и остановки. Поэтому […]

Completed.andThen результаты в "other is null"

У меня есть следующий код: fun edit(note: Note): Completable = getValidationCompletable(note).andThen(repository.insertOrUpdate(note)) private fun getValidationCompletable(note: Note): Completable { return if (!note.isValidForEdit()) { Completable.error(IllegalArgumentException("note failed validation before edit")) } else { Completable.complete() } } в случае, когда note.isValidForEdit() возвращает false, я получаю следующее: java.lang.NullPointerException: other is null at io.reactivex.internal.functions.ObjectHelper.requireNonNull(ObjectHelper.java:39) at io.reactivex.Completable.concatWith(Completable.java:1040) at io.reactivex.Completable.andThen(Completable.java:908) Может ли кто-нибудь пролить […]

Как динамически масштабировать отскок потока эмиссионных выбросов?

У меня есть буферизованный поток, ожидающий заданного количества времени молчания, прежде чем опубликовать список элементов, которые были буферизованы: INTEGERS .share() .buffer(INTEGERS.debounce(DEBOUNCE_TIME,TimeUnit.MILLISECONDS,scheduler)) .map { durations -> … } Я бы хотел, чтобы DEBOUNCE_TIME динамически настраивался в зависимости от среднего значения буферизированных элементов, но мне сложно понять, как это достичь.

Java – общий для Kotlin generic. Возвращать общий метод

Попытка конвертировать проект из Java в Kotlin. Я застрял в методе, который возвращает ObservableTransformer из RXJava 2 Ява protected <T> ObservableTransformer<T, T> onNetworkError() { return observable -> observable .doOnError(throwable -> networkError.setValue(throwable)); } Преобразование этого с помощью intellij ide вызывает ошибку. Ява в Котлин, используя идеал protected fun <T> onNetworkError(): ObservableTransformer<T, T> { return { observable […]

RxJava BehaviorSubject не испускает последний элемент?

У меня есть простая RxJava, используя ReplaySubject, я могу получить результат, где печатаются все 3 числа. val observable : Observable<Int> = Observable.just(1, 2, 3) val subject = ReplaySubject.create<Int>() observable.subscribe(subject) subject.subscribe{ result -> System.out.println("Start $result in Subscription Result") } Когда я перехожу к Поведению, я ожидаю, что будет напечатано третье число, т. Е. 3, поскольку я […]

Intereting Posts
Как объявить параметр как функцию без возвращаемого значения? java.lang.NoClassDefFoundError: kotlin / jvm / internal / Intrinsics Ошибка проверки валидации регулярным выражением номерного знака автомобиля Как хранить временную переменную при инициализации объекта Kotlin? Каков правильный способ объявить тип переменной в android с помощью Kotlin? Как использовать асинхронный Kotlin и ждать факториалов? Почему Котлин не разрешает использовать какой-либо код в основном конструкторе? Использование исключительного метода CompletedFuture в Котлине Добавление «предоставленной» конфигурации в библиотеку kotlin / java с использованием gradle Android Build Crashes после подписанной сборки Почему у kotlin есть функции componentN в классе данных, если у них уже есть геттеры и сеттеры? проект kotlin не может быть построен в gradle (не может найти ссылку) Как создавать функции с совместимыми параметрами / результатами в Котлине? Пользовательский Glide ModelLoader для изображений base64 Swift – выход из внешней функции из закрытия