如何对 Reactor Flux 流中的值求和？

假设我有一个存储库findAll()返回一个方法Iterable of State, where State是一个代表美国州的类，有两个字段（带有 getter/setter）：name, and population.

我想获得所有人口字段的总和State在我的通量中。 我从 Iterable 创建一个 Flux，如下所示：

Flux f = Flux.fromIterable(stateRepo.findAll());

我已经有了我的 Flux，但我不知道有什么好方法来总结它的值。 我尝试过类似的东西

int total = 0;
f.map(s -> s.getPopulation()).subscribe(p -> total += v);
return total;

然而，编译器表示总计“应该是最终的或实际上是最终的”。添加final显然行不通，因为我正在尝试添加它。

我如何对 Flux 进行求和（或任何其他聚合函数）？

Use reduce method:

@GetMapping("/populations")
    public Mono<Integer> getPopulation() {
        return Flux.fromIterable(stateRepo.findAll())
                .map(s -> s.getPopulation())
                .reduce(0, (x1, x2) -> x1 + x2)
                .map(this::someFunction); //you can also handle the sum, if you wish
    }