Articles of реактивный

Как получить доступ к Mono <T> При обработке исключения с помощью onErrorMap ()?

В классе данных я определил, что «имя» должно быть уникальным для всей коллекции mongo: @Document data class Inn(@Indexed(unique = true) val name: String, val description: String) { @Id var id: String = UUID.randomUUID().toString() var intro: String = "" } Поэтому при обслуживании я должен зафиксировать неожиданное исключение, если кто-то снова передает одно и то же […]

RxJava2 switchIfEmpty и проверка выполнения

так что .. представьте, что у меня есть метод, подобный этому: LocalDatabase: public Observable<PoiObject> getPoiObject() { return Observable.defer { PoiObject object = poiDao.getPoiObject(); if(object == null) { return Observable.empty(); } else { return Observable.just(object); } } } теперь у меня есть другой способ где-то еще: Обслуживание: public Observable<PoiObject> getPoiObject() { return localDatabase.getPoiObject() } public Observable<PoiObject> […]

Как получить текущий веб-запрос с помощью Vert.x Web?

Я пишу проект с использованием Hibernate (JPA) + Vert.x Web (Kotlin), и мне нужно связать EntityManager с веб-запросом, я имею в виду, что я хочу создать EntityManager для каждого веб-запроса. Мне нужно получить текущий веб-запрос от VertX, используя какой-то статический метод (объект в Котлине). Есть ли способ сделать это? Или я ошибаюсь, так как VertX […]

RxJava Live Reactive Queue (с выключенным переключателем)

Работа над Android-приложением в котлин. Мне нужно настроить систему, чтобы иметь возможность выполнять работу из живой очереди (и наблюдать за результатами работы в потоке). Но я также должен иметь возможность переключать «обработку очереди» в зависимости от пары внешних факторов (которые также поступают как потоки), таких как networkIsAvailable (Observable<Boolean>) . Я не могу использовать Observable.fromIterable() потому […]

Как проверить, нет ли Моно?

Я разрабатываю приложение с Spring Boot 2.0 и Kotlin, используя среду WebFlux. Я хочу проверить, выходит ли пользовательский идентификатор перед сохранением транзакции. Я застрял в простой вещи, такой как проверка, если моно пусто. fun createTransaction(serverRequest: ServerRequest) : Mono<ServerResponse> { val transaction = serverRequest.body(BodyExtractors.toMono(Transaction::class.java)) transaction.flatMap { val user = userRepository.findById(it.userId) // If it's empty, return badRequest() […]

Собственная собственность Котлина

В ReactiveUI мы можем использовать whenAny() для создания наблюдаемого из свойства или группы свойств. Как я могу достичь чего-то подобного в Котлине?

Раздвижное окно RxJava

У меня есть наблюдаемое значение, которое испускает данные, и я хочу сначала загрузить его в течение трех секунд, а затем после первого буфера должно быть скользящее значение в одну секунду. Это больше похоже на buffer(timespan,unit,skip) где пропускается время. Образец: ObservableData,TimeStamp : (5,1),(10,1.5),(30,2.8),(40,3.2),(60,3.8),(90,4.2) ExpectedList : {5,10,30},{10,30,40,60},{30,40,60,90} Я могу добиться этого, создав пользовательский оператор. Я просто хочу […]

RXJava – concat не работает

У меня проблема с RXJava и Kotlin. Я использую LiveData и Rx, моя проблема заключается в том, что метод concat не объединяет два массива, которые у меня есть в данных Dummy. Это мой код: disposables. add( Observable.concat(Observable.just(DummyContent.COMPANIES), Observable.just(DummyContent.COMPANIES)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe({ Timber.d("get companies success ${it.size}" ) companiesLiveData.value = it },{ t -> Timber.e(t, "get companies […]

Intereting Posts
Как интерпретировать и переводить код kotlin в java? Retrofit-Vertx с RxJava2 в Kotlin IllegalStateException message == null Kotlin: Выполнение функциональных параметров в теле вызывающего Демонстрационная версия Corda V1.0 IOU не работает в Windows kotlin springboot application – почему нет функции с выражением тела? динамический dsl с использованием kotlin с поддержкой контента Рекурсивная проблема с toString в Котлине Как принудительно ввести пустую, ненулевую строку в Котлин? Преобразование процедурных методов стиля в функциональный стиль Использование сторонних пользовательских интерфейсов с TornadoFX Не удается разрешить строку, переданную параметру vararg в функции расширения UnsupportedOperationException при построении проекта Kotlin в Idea Как определить функцию oneline, вызывающую функцию с нулевыми переменными Котлин с, если не нуль Использование объекта-компаньона для возврата экземпляра класса в Котлин