Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Acabo de comenzar mi viaje con Reactor y me he bloqueado en la siguiente implementación. java List<Integer> l = Arrays.asList(1, 2, 3, 4); Integer firstValuePresent = 0; for (int i = 0; i < l.size(); i++) { x = checkDb(l.get(i));//db o cualquier llamada a io if (x.isPresent())//verificar el primer valor . . . Read more
Necesito copiar la propiedad Friends (que es un ArrayList) de un Mono<PersonEntity> a un Mono<UserEntity> (que no tiene la propiedad Friends en la base de datos), pero no encuentro la manera correcta de hacerlo, así que cuando mapeo el Mono<UserEntity> a Dto, el campo Friends se convierte en un array . . . Read more
Estoy utilizando los puntos finales funcionales de Spring Webflux y me gustaría generar una definición openAPI para esto. Agregué SpringDoc, pero la definición openAPI resultante está vacía: json { "openapi": "3.0.1", "info": { "title": "Definición OpenAPI", "version": "v0" }, "servers": [ { "url": "http://localhost:8080", "description": "URL del servidor generado" } . . . Read more
Tengo una capa de servicio que utiliza Spring Webflux y Reactor, y estoy escribiendo pruebas unitarias para esto. Pude probar el escenario de respuesta correcta, pero no estoy seguro de cómo probar onErrorResume() utilizando StepVerifier. Además, por favor, háganme saber si hay una mejor manera de manejar excepciones en mi . . . Read more
Tengo un método java-lang @Service public class MyService { public Mono<Integer> processData() { … // operación reactiva muy larga } } En el flujo normal del programa, llamo a este método de forma asíncrona a través de un evento de Kafka. Para fines de prueba, necesito exponer el método como . . . Read more