如何求和Reactor通量流中的值？

Question

假设我有一个具有findall()方法的存储库，该方法返回state的iterable，其中state是一个表示美国状态的类，它有两个字段（带有getter/setters):name和population。

我想获得Flux中所有状态的填充字段之和。我从Iterable创建了一个Flux，如下所示：

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

我有我的通量，但我不知道一个好的方法来总结它的价值。我试过

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

然而，编译器说total“应该是最终的或有效的最终的”。添加final显然不会起作用，因为我正在尝试添加。

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

Answer 1

使用reduce方法：

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