Описание тега spring-reactive
0
ответов
Использование Flux as() при наличии transform () и compose ()
Я искал этот вопрос, но не получил четкого ответа на вопрос, как использовать as() и в каких сценариях. Пожалуйста, помогите мне понять.
13 окт '19 в 08:49
1
ответ
Spring WebClient: повторите попытку с WebFlux.fn + response-addons
Я пытаюсь добавить условную повторную попытку для WebClient с Kotlin Coroutines + WebFlux.fn + response-addons: suspend fun ClientResponse.asResponse(): ServerResponse = status(statusCode()) .headers { headerConsumer -> headerConsumer.addAll(head…
24 мар '20 в 11:18
0
ответов
Реактивный веб-клиент Spring для использования хранилища доверенных сертификатов IBM WAS по умолчанию вместо хранилища по умолчанию, расположенного в jre\lib\security\cacerts
Как я могу заставить org.springframework.web.reactive.function.client.WebClient использовать хранилище доверенных сертификатов IBM по умолчанию, которое обычно находится в ${WAS_INSTALL_ROOT}/profile/default/config/cells/myhostNode01Cell/nodes/myhos…
26 мар '20 в 02:58
1
ответ
в чем разница между map и doOnNext в flux? (т.е. проектный реактор)
В Flux функция карты также выполняется для каждого элемента в потоке. Для doOnNext функция также выполняется для каждого элемента (испускаемого) в потоке. в чем разница с точки зрения пользователя? почему существует два подобных метода? Мог бы объяс…
06 фев '20 в 23:39
2
ответа
Использование Mono <T> в Spring для заполнения объекта Cloud Firestore
Я использую spring-cloud-gcp-starter-data-firestore для доступа к Google Cloud Firestore в моем приложении Java Spring. Сейчас моя сущность выглядит так: public class Subscription { public String userId; public String companyId; // other properties …
28 янв '20 в 18:22
0
ответов
POST API с использованием Spring WebClient через HTTP2
Я пишу JUNIT для push-уведомлений с использованием токенов аутентификации. Теперь API Apple push основан на HTTP2, и я хочу использовать для этой цели spring WebClient. private static WebClient webClient = WebClient .builder() .baseUrl("https://api.…
23 май '20 в 19:19
1
ответ
r2dbc-postgresql 0.8.0.RC1 in Spring Boot 2.2 not working properly
After i changed the version of my spring webflux (spring boot 2.2.0.m3 to 2.2.2.RELEASE) and r2dbc (spring-data-r2dbc 1.0.0.M2 to 1.0.0.RELEASE) and r2dbc-postgresql (1.0.0.M7 to 0.8.0.M8) project i keep getting this error java.lang.IllegalArgumentE…
20 дек '19 в 03:52
1
ответ
Подключиться к MSSQL с помощью Spring Reactive (R2DBC), ошибка создания bean-компонента
В настоящее время я пытаюсь установить соединение с базой данных с Microsoft SQL Server. К сожалению, я не могу понять, почему это не работает. И сообщение об ошибке, к сожалению, не может дать мне точную информацию. Стартовый класс @ComponentScan({…
25 май '20 в 11:27
1
ответ
Не удается записать данные в ElasticSearch с помощью AbstractReactiveElasticsearchConfiguration
Я пытаюсь записать данные в свой локальный контейнер Docker Elasticsearch (7.4.2), для простоты я использовал AbstractReactiveElasticsearchConfiguration, предоставленный Spring, также переопределяя функцию entityMapper. Я построил свой репозиторий, …
25 ноя '19 в 21:00
0
ответов
Связанные запросы Spring WebClient, выполняемые для синхронных API
Я знаю, что это слишком много контекста, но, пожалуйста, потерпите меня. Мы создаем службу на основе Spring Boot, которая в основном считывает некоторые данные из внешнего синхронного API через HTTP-вызовы и, в зависимости от некоторых конкретных фл…
14 апр '20 в 19:30
0
ответов
Объединение вызовов репозитория
Правильный способ объединения нескольких методов в цепочку вызывает реактивный, т.е. без блокировки. Вот похожий вопрос. Цепочка вызовов методов с использованием RxJava /** * Delete a user, including VerificationToken and PasswordResetToken if exist…
15 окт '19 в 12:44
2
ответа
Как мы можем преобразовать объект Flux <Employe> в объект Mono <Customers> в Spring Reactive
Как мы можем преобразовать объект Flux в объект Mono? Flux<Сотрудник> empFlux = getService(); // Он вернет список сотрудников Employe { private String id; информация о частной строке;} // необходимо преобразовать данные empFlux в Mono public class C…
16 окт '19 в 05:24
1
ответ
Как дождаться, когда все Одноразовые элементы будут закончены?
Давайте рассмотрим следующий код: List<Mono<String>> monoList= apiCall(); List<Disposable> disposableList = monoList.stream() .map(m-> m.subscribe(str-> { log.info("Mono is finished with "+ str); }) ).collect(Collectors.toLis…
18 ноя '19 в 15:13
1
ответ
Как преобразовать List <Mono <String>> в Flux <List <String>>?
List<Mono<String>> responses = apiCall() Я бы хотел получить Flux<String> ждать всех моно из списка. Как я мог этого добиться? PS Я нашел аналогичный вопрос, но мне нужна обратная операция /questions/21509400/reaktornyij-potokmyobj…
18 ноя '19 в 14:27
0
ответов
получить объект запроса в реактивном контроллере Spring
Я пытаюсь использовать реактивную библиотеку Spring, и я пытаюсь извлечь некоторые заголовки из запроса. С Spring MVC (tomcat) у меня было три варианта: Получите объект запроса в качестве аргумента: public void testApi(HttpServletRequest serverReque…
19 ноя '19 в 19:51
1
ответ
Реактор: Flux <объект> .subscribe() vs. .toStream()
У меня есть функция: Flux queryPerson (), которая запрашивает базу данных для создания объектов и возврата их в Flux. Когда я использую.subscribe(), приложение просто запускает код и выходит. Он не ждет, пока вернутся результаты запроса. Но когда я …
25 ноя '19 в 22:53
3
ответа
Как вызвать исключение в части ошибки реактивного вызова Spring WebClient?
Я хотел бы, чтобы следующий метод генерировал настраиваемое исключение в случае возникновения ошибки: @Service public class MyClass { private final WebClient webClient; public MatcherClient(@Value("${my.url}") final String myUrl) { this.webClient = …
02 окт '19 в 12:37
3
ответа
Невозможно подключиться к MongoDB в приложении Spring Boot
Я только что создал очень простой проект Spring Boot, используя Spring Tool Suite с mongoDB-reactive зависимости и запускаю приложение, но я продолжаю получать следующие исключения 2019-11-27 00:31:19.699 ИНФОРМАЦИЯ 11988 --- [localhost:27017] org.m…
26 ноя '19 в 22:08
1
ответ
Как дождаться, когда все моно из списка будут завершены (не имеет значения успешно или нет)
У меня такой код: List<Mono> monoList = foo(); //await when all Monos are finished try { Flux.fromIterable(monoList) .flatMap(Function.identity()) .then() .block(); } catch (Exception e) { log.warn("error", e); } Он отлично работает, когда все…
13 дек '19 в 02:43
0
ответов
Как отправить запрос GET с помощью Angular 8 и как обработать входящий ответ APPLICATION_STREAM_JSON_VALUE
Я показываю конечную точку с помощью Spring Boot и Webflux, которая возвращает бесконечный поток чисел, по одному каждую секунду: @GetMapping(value = "/infinitestreamflux", produces = MediaType.APPLICATION_STREAM_JSON_VALUE) @CrossOrigin(origins = "…
06 фев '20 в 17:10