Tag: PROJECT-REACTOR
Tenemos una aplicación de Spring que utiliza WebClient para realizar algunas llamadas a una API externa. En el entorno local, los nombres de los hilos en el registro son [reactor-http-nio-X]: 2021-12-01 15:58:42.960 | | DEBUG 37528 — [ctor-http-nio-5] o.s.s.w.s.u.m.OrServerWebExchangeMatcher : Tratando de hacer match usando PathMatcherServerWebExchangeMatcher{pattern='/webjars/', method=null} 2021-12-01 15:58:42.960 | . . . Read more
En la clase de prueba JdbcWithMonoTest existen 2 pruebas foo y bar. La única diferencia entre estas 2 pruebas es que bar está escrita con .publishOn(Schedulers.boundedElastic()). Cuando ejecuto ambas pruebas los resultados son que foo pasa como se espera y bar falla con el mensaje: java.lang.AssertionError: expectation “expectNextMatches” failed (predicate . . . Read more
Necesito verificar si una subcadena está contenida en el título de la tienda o existencias en esta tienda. @ Override public Flux searchShopsBySearchingTextInShopsAndStocks (String searchText) { // Recibí Flxux & lt; List & lt; Shop & gt; & gt; return shopRepo.findAll (). // luego verifico si la subcadena está en . . . Read more
Quiero ejecutar Flux en paralelo, pero recopilar el resultado en secuencia. Supongamos que tengo un flux de [3,2,1], después de realizar alguna tarea en paralelo, espero que el resultado siga siendo [3,2,1]. val mono = Flux.fromIterable(3 downTo 1) .map { it.toString() } // esto devolverá el mismo número .flatMap { . . . Read more
Tengo una lista de Mono que me gustaría procesar, pero deben ser ejecutados secuencialmente y también deben ejecutar el siguiente solo después de que el Mono anterior esté completo. private Mono<List<Result>> processGoals(List<> goals,Data data) { List<Mono<Result>> plans = goals .stream() .map(plan -> processGoal(plan, data)) .collect(Collectors.toList()); } Intenté usar: return Flux.concat(plans).subscribeOn(Schedulers.single()).collectList(); . . . Read more