Tag: PROJECT-REACTOR
Tengo una lista que contiene 240 elementos, esta lista tarda más de 1 hora en enviarse completamente usando un bucle “for”. List<Map<String, Object>> conventions = mapConventions(objects, referentialService); for(Map<String, Object> item : conventions) { webClient.post() .uri(configProperties.getUrl().getConvention() + CONVENTION) .bodyValue(objectMapper.convertValue(item, JsonNode.class)) .retrieve() .bodyToMono(String.class); } Así que seguí este artículo para enviarlo simultáneamente . . . Read more
Supongamos que tengo dos fuentes de eventos históricos, y que los eventos de cada fuente están ordenados cronológicamente. ¿Cómo puedo fusionar estas fuentes utilizando Reactor para que los eventos en el Flujo fusionado se emitan en orden cronológico? En RxNET, se puede utilizar una combinación de Observable.Generate() y HistoricalScheduler para . . . Read more
Digamos que tengo las siguientes líneas: repositorio.findUser(name = “John Doe”) .map { // Se encontró al usuario, continuar procesando } .switchIfEmpty( // Solo registrar que no se encontró al usuario ) Mi enfoque actual, que no es el mejor pero funciona, es simplemente colocar el registro en otra función y . . . Read more
Disculpa mi pregunta tonta. Soy muy nuevo en el proyecto reactor. Y esta pregunta me está molestando mucho. Si flux puede manejar de 0 a N elementos y Mono puede manejar de 0 a 1 elemento, ¿por qué existe el mono? ¿No puede flux manejar también de 0 a 1 . . . Read more
Supongamos que tenemos la siguiente función: fun getAnnualData(tenant: String): Flux<dashboardresponse> { val year = LocalDate.now().year val annualExpenses = expenseFinder.sumAllByYearAndTenant(year = year, tenant = tenant) val warehouseExpenses = expenseFinder.sumWarehouseByYearAndTenant(year = year, tenant = tenant) val annualRevenues = revenueFinder.sumAllByYearAndTenant(year = year, tenant = tenant) return annualExpenses.zipWith(annualRevenues) .filter { it.t1._id?.year == year } . . . Read more