Project Reactor：求和两个 Mono<Integer> 而不阻塞

问题描述

假设我们有：

Mono<Integer> int1 = Mono.just(1) 和 Mono<Integer> int2 = Mono.just(10)。我想在不阻塞的情况下获得这两个整数的总和。

以阻塞方式，我会这样做： Mono<Integer> result = Mono.just(int1.block() + int2.block())

提前致谢！

解决方法

试试zip：

Mono<Integer> int1 = Mono.just(1); //or any other mono,including lazy one
Mono<Integer> int2 = Mono.just(10); //same


Mono<Integer> sum = Mono.zip(
    int1,int2,//zip defaults to producing a Tuple2
    //but for the 2 args version you can provide a BiFunction
    (a,b) -> a + b
);

//if you want to verify,eg. in a test:
StepVerifier.create(sum)
    .expectNext(11)
    .verifyComplete();