Parallelflux - параллельное выполнение с несколькими вызовами API вниз по течению ⇐ JAVA

[Anonymous]

У меня есть 3 входных идентификатора, которые следует обрабатывать параллельно. Для этого я использовал ParallElflux, как показано ниже. С параллельным потоком каждый идентификатор будет обрабатываться с разными потоками. Но вызовы вниз по течению будут последовательными с тем же присвоенным потоком.

Код: Выделить всё

Flux.fromIterable(idList)
.parallel()
.runOn(Schedulers.boundedElastic()
.flatMap(id -> Mono.fromCallable(()-> Pair.of(id, getInfoByID(id))))
.sequential()
.collect(Collector.toList()).block();
< /code>
private Info getInfoByID(String id){
var mono1= api1.getDetails();
var mono2= api2.getDetails();
Mono.zip(mono1, mono2)
.map(tuple2 -> {
…………
}).block();
}

Спасибо


Подробнее здесь: https://stackoverflow.com/questions/795 ... -api-calls