Preguntas etiquetadas [project-reactor]

1 votos
1 respuestas
¿El registro de una operación no bloqueante en Spring Webflux?
¿Debo preocuparme por el registro en la consola, usar Slf4j sobre Logback, ser una operación de bloqueo? No estaba seguro, así que he estado...
0 votos
0 respuestas
Manipulación del cuerpo de la pasarela de la nube de primavera.
Soy nuevo en Spring Cloud Gateway y estoy intentando implementar una de las aplicaciones Spring Boot 2 + sin bloqueo con Netty. Como parte de es...
1 votos
1 respuestas
Salir del bucle sin ejecutar el mapa o el plano Mapa
Mientras estoy iterando el código de Flux, tengo problemas para salir del final del método. He intentado todas las posibilidades pero sin sue...
preguntó hace 4 meses
1 votos
1 respuestas
¿Hay una diferencia entre doOnSuccess vs doOnNext para un Mono?
Digamos que tiene Mono<Integer> someIntegerSource = Mono.just(5) y desea asignarlo a una variable. ¿Hay alguna diferencia entre estos f...
preguntó hace 4 meses
0 votos
1 respuestas
Asignador ByteBuf en Reactor Netty
¿Hay alguna forma de obtener un asignador de ByteBuf utilizado en Reactor Netty en un controlador de solicitudes? Similar a cómo se puede hacer...
preguntó hace 4 meses
0 votos
1 respuestas
Cómo manejar las excepciones generadas en suscripciones a procesadores en Project Reactor
Considere la siguiente prueba: @Test void test() { DirectProcessor<Object> objectTopicProcessor = DirectProcessor.create(); Run...
preguntó hace 4 meses
0 votos
2 respuestas
Problema con la combinación de cliente web con Mono y Flux
   Hola, tengo Flux y durante la iteración de cada elemento se crea un nuevo mono. También tengo otro mono fuera de flujo. Y desea hacer lo sigu...
0 votos
1 respuestas
¿Cuándo uso Mono.flatMapIterable vs Mono.flapMapMany?
Nuevo en el reactor, tratando de comprender que Mono.flatMapMany y Mono.flatMapIterable se relacionan con frecuencia con los Mono de un objeto q...
preguntó hace 4 meses
3 votos
2 respuestas
Proyecto Reactor, utilizando un sumidero de flujo fuera de la creación lambda
Cuando se inicie mi servicio, quiero construir una canalización simple. Me gustaría aislar el sumidero de flujo, o un procesador, para emitir...
preguntó hace 4 meses
0 votos
1 respuestas
¿Por qué ParallelFlux no tiene collectList () similar a Flux?
El Flux tiene collectList () que es muy conveniente de usar, sin embargo no hay collectList () en ParallelFlux, estoy tratando de entender la ra...
preguntó hace 4 meses
0 votos
1 respuestas
Use el valor del resultado mono de la solicitud de base de datos en otra solicitud
Quiero obtener un usuario por su nombre de usuario, asignarlo como autor de una nota y luego guardar esa nota en la base de datos. El problema e...
0 votos
1 respuestas
División de un flujo de cadena en flujo múltiple
Tengo un flujo de cadenas como tal field1=value1,terminalField=true,field2=value2,field3=value3,terminalField=true que me gustaría dividir...
preguntó hace 4 meses
1 votos
1 respuestas
Probar la aplicación de contrapresión a un flujo en una aplicación de Reactor
Estoy usando Reactor para leer un tema de Kafka. La elaboración de cada mensaje solicita una consulta en un MongoDB, que es más lento que la lec...
1 votos
1 respuestas
Reactor de primavera: ¿Cómo comprimir dos Flux, pero con orden?
Supongamos que tengo dos servicios externos. Digamos que tenemos un artículo Foo y serviceA devuelve el artículo A mientras que serviceB devuelv...
preguntó hace 4 meses
1 votos
1 respuestas
La forma más eficiente de dividir un flujo a varios flujos en Reactor 3
En Reactor 3, ¿cuál es la forma más eficiente de dividir un flujo heterogéneo en múltiples flujos mediante la coincidencia de patrones? (Y las o...
preguntó hace 4 meses
1 votos
1 respuestas
¿Cómo puedo procesar eventos de flujo en paralelo entre sí?
Tengo secuencias de eventos entrantes que deben enriquecerse y procesarse en paralelo a medida que llegan. Estaba pensando que el Proyecto Re...
preguntó hace 4 meses
0 votos
0 respuestas
Cómo agrupar un Flujo en grupos y avisar cuando un grupo no alcance algún tamaño después de un período de tiempo
Estaba tratando de encontrar una solución reactiva para el siguiente problema: digamos que tengo un flujo que contiene elementos que se ven así:...
preguntó hace 4 meses
0 votos
3 respuestas
Llamada de flujo web de resorte síncrono que mantiene el orden de operación
Tengo un caso de uso simple y no estoy seguro de cómo hacerlo, ya que soy nuevo en el webflux de primavera. Estoy usando spring boot webflux...
0 votos
1 respuestas
Reactor: descargue n imágenes en paralelo y la falla de una no debería afectar al resto
Tengo un caso de uso en el que quiero buscar rutas de imágenes (mediante n llamadas REST). Quiero que estas llamadas se ejecuten en paralelo y l...
preguntó hace 5 meses
0 votos
1 respuestas
Reactor: descargue n imágenes en paralelo y la falla de una no debería afectar al resto
Tengo un caso de uso en el que quiero buscar rutas de imágenes (mediante n llamadas REST). Quiero que estas llamadas se ejecuten en paralelo y l...
preguntó hace 5 meses
1 votos
1 respuestas
Necesito hacer que el servicio sea reactivo sin repositorio [cerrado]
Mi tarea es hacer que UserService sea reactivo usando Flux /Mono. Entiendo cómo funcionan flux y mono, pero solo los hice con repositorios y...
2 votos
0 respuestas
¿Qué sucede cuando se devuelve el flujo desde el controlador web de Spring?
Soy comparativamente nuevo para las API reactivas y tenía curiosidad por lo que estaba sucediendo tras bambalinas cuando devolvemos un Flux desd...
preguntó hace 5 meses
1 votos
4 respuestas
¿Cómo reutilizar una variable en múltiples operadores Mono?
[posible duplicado, pero no he encontrado ninguno hasta ahora] Considera este código: Mono.just(myVar) .flatMap(MyClass::heavyOperation...
preguntó hace 5 meses
0 votos
1 respuestas
Spring Reactor: ¿Cómo lanzar una excepción cuando el editor emite un valor?
Estoy aprendiendo programación reactiva con Reactor y quiero implementar un escenario de registro donde un usuario pueda tener muchas cuentas as...
0 votos
1 respuestas
Necesita ayuda para comprender la ejecución del mapa plano para el ejemplo de código mencionado
Estoy intentando llamar a un api & acumulando resultados utilizando Flux & Webclient. Quiero entender la ejecución del operador flatMap...
preguntó hace 5 meses