Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Durante los últimos años he estado viendo cambios en el mundo de la “Programación/Sistema Reactivo”. Para implementar sistemas no bloqueantes, asíncronos y con presión trasera, estos son muy buenos candidatos. Pero a menudo trato de ver cuál(es) es el mejor entre Akka/ProjectReactor/RxJava/Vertx para construir sistemas reactivos y que también puedan . . . Read more
Tengo código síncrono que quiero convertir en no bloqueante con reactor. Quiero llamar en paralelo a diferentes URI, las llamadas pueden devolver una respuesta, un error o nada. Hay 3 casos: Una solicitud devuelve una respuesta, la retorno sin esperar a que se completen las otras solicitudes. Si otras solicitudes . . . Read more
Reactor tiene el operador switchOnNext que refleja una secuencia de editores, cancelando la suscripción anterior cada vez que un nuevo editor está disponible: Para mi caso de uso, necesito una variación de esta temática, donde en lugar de cancelar el primer editor antes de suscribirme al siguiente, continúo reflejando la . . . Read more
Según la documentación: maxIdleTime – El tiempo después del cual el canal es elegible para ser cerrado cuando está inactivo (resolución: ms). Por defecto: el tiempo de inactividad máximo no está especificado. maxLifeTime – El tiempo de vida total después del cual el canal es elegible para ser cerrado (resolución: . . . Read more
Entonces digamos que tenemos algo como: public class SomeService { … public Flux<String> getStringsFromWebServer() { return webClient.get() .uri(this::generateSomeUrl) .retrieve() .bodyToMono(SomePojo.class) .map(SomePojo::getStringList) .flatMapMany(Flux::fromIterable); } ¿Tiene sentido escribir pruebas que se vean así? void getStringsFromWebServer<em>shouldParseInOrderOfReceivingStrings() { // dado // He simulado un WebClient, que está conectado a un servidor web simulado // . . . Read more