Resultados de la búsqueda a petición "project-reactor"
¿Cómo hacer una secuencia de operaciones y asegurar que una operación se complete antes de la siguiente en la aplicación web Spring Reactor?
Tengo la aplicación web Spring Boot 2 en la que necesito identificar al visitante del sitio mediante cookies y recopilar estadísticas de visualización de la página. Entonces necesito interceptar cada solicitud web. El código que tuve que escribir ...
¿Es realmente necesario usar Hystrix con la aplicación reactiva spring boot 2?
Estoy trabajando en un proyecto en el que estamos trasladando algunos de nuestros microservicios de Spring-MVC a Spring-Webflux para probar el paradigma reactivo. Buscando ayuda en el repositorio github de hystrix, hemos notado que el proyecto ...
¿Cómo recopilar respuestas API paginadas usando Spring WebClient de arranque?
Tengo una respuesta paginada de una URL, quiero seguir presionando la URL de la página siguiente que obtengo de la respuesta anterior y seguir recolectando elementos hasta que no tenga una URL de "nextPage" en mi respuesta. ¿Cómo lograr esto de ...
¿Por qué Spring ReactiveMongoRepository no tiene un método para guardar Mono?
Tengo un MovieRepository que extendió ReactiveMongoRepository. Quiero guardar un solo POJO de forma reactiva. Pero ReactiveMongoRepository no proporciona un método de guardado para Mono o Publisher. Tengo que usarblock() método o utilizar ...
Cómo leer correctamente Flux <DataBuffer> y convertirlo en una sola entrada
Estoy usandoWebClient y personalizadoBodyExtractorclase para mi aplicación de arranque de primavera WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(MediaType.APPLICATION.XML) .exchange() .flatMap(response -> { ...
¿Cómo “gestionas” realmente el número máximo de hilos web utilizando la Programación Reactiva de Spring 5?
Al usar un enfoque clásico de Tomcat, puede darle a su servidor un número máximo de hilos que puede usar para manejar las solicitudes web de los usuarios. Usando el paradigma de Programación Reactiva y Reactor en Spring 5, podemos escalar mejor ...
Cómo registrar cuerpos de solicitud y respuesta en Spring WebFlux
Quiero tener un registro centralizado de solicitudes y respuestas en mi API REST en Spring WebFlux con Kotlin. Hasta ahora he intentado este enfoque @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { ...
¿Cómo crear un Spring Reactor Flux a partir del flujo de integración Http?
Tengo una pregunta muy parecida a esta.¿Cómo crear un Spring Reactor Flux a partir de una cola ActiveMQ? [https://stackoverflow.com/questions/43126775/how-to-create-a-spring-reactor-flux-from-a-activemq-queue] Con una diferencia, los mensajes ...
El método publishingOn of Flux no funciona como se esperaba
Estoy tratando de integrar un consumidor de bloqueo comoFlujosuscriptor en Reactor Aluminium-SR1. Me gustaría usar un paraleloProgramador, para ejecutar las operaciones de bloqueo al mismo tiempo. Implementé una clase principal para describir mi ...
Cómo convertir Mono <List <String>> en Flux <String>
Estoy convirtiendo un pequeño proyecto escrito en RxJava 1.x a Reactor 3.x. Todo está bien, excepto que no pude encontrar cómo reemplazarflatMap(Observable::from) con la contraparte apropiada. yo tengoMono<List<String>> y necesito convertirlo ...
Página 1 de 2