Resultados de la búsqueda a petición "project-reactor"

2 la respuesta

Spring 5 Web Reactive - ¿Cómo podemos usar WebClient para recuperar datos transmitidos en un Flux?

La documentación actual de hitos (M4) muestra un ejemplo sobre cómo recuperar unMono utilizandoWebClient: WebClient webClient = WebClient.create(new ReactorClientHttpConnector()); ClientRequest<Void> request ...

3 la respuesta

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 ...

1 la respuesta

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 ...

1 la respuesta

¿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 ...

6 la respuesta

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 { ...

1 la respuesta

¿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 ...

3 la respuesta

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 -> { ...

1 la respuesta

¿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 ...

2 la respuesta

¿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 ...

1 la respuesta

¿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 ...