我有一个返回 Mono<Output>
的方法:
interface Processor {
Mono<Output> process(Input input);
}
我想为一个集合执行这个processor
方法:
List<Input> inputs = // get inputs
Processor processor = // get processor
List<Mono<Output>> outputs = inputs.stream().map(supplier::supply).collect(toList());
但是我想得到的不是List<Mono<Output>>
,而是包含聚合结果的Mono<List<Output>>
。
我尝试使用reduce
,但最终结果看起来非常笨拙:
Mono<List<Output>> result = inputs.stream().map(processor::process)
.reduce(Mono.just(new ArrayList<>()),
(monoListOfOutput, monoOfOutput) ->
monoListOfOutput.flatMap(list -> monoOfOutput.map(output -> {
list.add(output);
return list;
})),
(left, right) ->
left.flatMap(leftList -> right.map(rightList -> {
leftList.addAll(rightList);
return leftList;
})));
我能用更少的代码实现这个吗?
Mono<List<Mono<Output>>>
。但我只需要Mono<List<Output>>
。这是我已经尝试过的方法。 - Ilya Zinkovich