Вопросы по теме 'spring-reactive'

Как вызвать исключение в части ошибки реактивного вызова Spring WebClient?
Я хотел бы, чтобы следующий метод генерировал настраиваемое исключение в случае возникновения ошибки: @Service public class MyClass { private final WebClient webClient; public MatcherClient(@Value("${my.url}") final String myUrl) {...
2766 просмотров

Как мы можем преобразовать объект Flux ‹Employe› в объект Mono ‹Customers› в Spring Reactive
Как мы можем преобразовать объект Flux ‹Employe> в объект Mono‹ Customers>? Flux ‹Сотрудник> empFlux = getService (); // Он вернет список сотрудников Employe {private String id; информация о частной строке;} // необходимо преобразовать данные...
79 просмотров

r2dbc-postgresql 0.8.0.RC1 в Spring Boot 2.2 не работает должным образом
После того, как я изменил версию моего весеннего webflux (весенняя загрузка 2.2.0.m3 на 2.2.2.RELEASE) и r2dbc (spring-data-r2dbc 1.0.0.M2 на 1.0.0.RELEASE) и r2dbc-postgresql (1.0 .0.M7 - 0.8.0.M8) я продолжаю получать эту ошибку...
308 просмотров

Сделайте асинхронный вызов SOAP в Spring WebFlux
У меня есть приложение Reactive Spring, использующее WebFlux с REST API. Каждый раз, когда пользователь вызывает мой API, мне нужно позвонить в службу SOAP, которая предоставляет WSDL, выполнить некоторую операцию и вернуть результат. Как мне...
3229 просмотров

Spring WebClient: повторите попытку с помощью WebFlux.fn + response-addons
Я пытаюсь добавить условный повтор для WebClient с помощью Kotlin Coroutines + WebFlux.fn + response-addons: suspend fun ClientResponse.asResponse(): ServerResponse = status(statusCode()) .headers { headerConsumer ->...
1411 просмотров

Spring Boot Couchbase Reactive не поддерживает разбиение на страницы
Я пытаюсь реализовать разбиение на страницы в моем приложении Reactive WebFlux, а моя БД - Couchbase. Документ Spring Data Couchbase позволяет мне передавать Pageable в качестве аргумента в моем репозитории. Flux<Person>...
174 просмотров