如何解决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();
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。