Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tuve la sensación a partir de los tutoriales de que devolver algo throwable no debería cambiar el tipo de retorno del método. Aquí están mis intentos: Cuando uso handle, todo está bien hasta que agrego .timeout(), entonces el tipo de retorno de la función cambia a Flux<object>. private Flux<string> exampleHandle() . . . Read more
Estoy teniendo dificultades para comprender el flujo del proceso Reactivo. Mi entendimiento es que, al manipular datos dentro de un Mono o Flux, se debe mantener la consistencia del tipo de datos. Sin embargo, cuando ocurren problemas dentro de ese proceso, algo similar a una excepción debe ser lanzada, lo . . . Read more
¿Es razonable implementar el mapeo dinámico de fromTo (escuchando cambios) de manera reactiva? Posibles soluciones: – Estilo de bloqueo al viejo estilo – Caché como Caffeine, etc. – Collections.synchronizedList<><><string, string=””>>> y procesarlo en un flujo</string,>
Estoy tratando de entender los paradigmas reactivos, pero la lógica parece contraria a mis necesidades. La situación es la etapa inicial de un proceso de registro: comenzar con los datos de registro, verificar si existe una cuenta para el correo electrónico proporcionado (obteniendo un objeto AccountDto o null) y procesar . . . Read more
Quiero subir archivos a un contenedor de archivos de Minio. Los archivos más pequeños funcionan correctamente con este código: private Mono<boolean> saveFileToMinio(FilePart filePart) { log.info(“A punto de guardar la base de datos en el contenedor de Minio…”); Mono<boolean> result = Mono.from( filePart.content().flatMap(dataBuffer -> { var bytes = dataBuffer.asByteBuffer().array(); dataBuffer.read(bytes); DataBufferUtils.release(dataBuffer); . . . Read more