代码之家 › 专栏 › 技术社区 › Aleksey Kozel

Mono如何订阅

project-reactor spring-webflux java

Aleksey Kozel · 技术社区 · 6 年前

我正在尝试创建以下链:

Mono<Object1> oneMono = Mono.just("1");
Mono<Object2> twoMono = Mono.just("2");

Mono<Mono<Object5>> resultMono = Mono.zip(oneMono, twoMono, (one, two) -> { 

    Mono<Object3> threeMono = Mono.just("3");
    Mono<Object4> fourMono = Mono.just("4");

    return Mono.zip(threeMono, fourMono, (three, four) -> {
        return "5";
    }
}) // get just Mono<Object5> here?

resultMono.subscribe(mono -> { 
    mono.subscribe();  // ugly double subscribe() !!
});

因此,我需要得到5分。但在执行1、2和3、4之前。

代码运行正常,但我想退出

从…起 Mono<Mono<Object5>> 和 double subscribe

到 Mono<Object5> 和 single subscribe 。

是否有Zip的模拟平面图?

1 回复 | 直到 6 年前

Dmitry 6 年前

嗯,你已经有了。您只需使用平面图:

Mono<String> oneMono = Mono.just("1");
Mono<String> twoMono = Mono.just("2");

Mono.zip(oneMono, twoMono, (one, two) -> {
    Mono<String> threeMono = Mono.just("3");
    Mono<String> fourMono = Mono.just("4");

    return Mono.zip(threeMono, fourMono, (three, four) -> {
        return "5";
    });
})
.flatMap(stringMono -> stringMono)
.doOnNext(System.out::println)
.subscribe();

推荐文章

Hermes Chavez · 如何将springboot rest端点转换为spring webflux反应端点

2 年前

Aliaksei · 保存前进行WebFlux检查

2 年前

Flavouski · 反应性异常处理

6 年前

Viraj · 反应式编程如何实现相关结果

6 年前

Leo Prince · Spring Weflux Rest API(带注释的控制器)的总处理时间

6 年前

ErosC · 为什么webflux的spring boot测试会忽略自定义jackson模块

6 年前

Aleksey Kozel · Mono如何订阅

6 年前

dschulten · spring集成:如何从WebFlux集成流创建spring反应堆通量?

6 年前

dschulten · spring集成:Webflux inboundGateway未映射到请求

6 年前

James Black · 使用Reform2和RxAndroid从Spring WebFlux获取响应

6 年前