时间戳

首页 > 解决方案 > 单核细胞增多症> 如何订阅

java - 单核细胞增多症> 如何订阅

问题描述

我正在尝试创建以下链：

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 的模拟 flatMap 吗？

标签： javaspring-webfluxproject-reactor

解决方案

好吧，你已经有了。你只需要使用 flatMap：

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();

推荐阅读