Mono#then 和 Mono#and 的区别?

给定以下单声道:


Mono<Void> mono1 = Mono.fromRunnable(() -> {

    System.out.println("sleep1");

    try {

        Thread.sleep(1000);

    } catch (InterruptedException e) {

        throw new IllegalStateException(e);

    }

    System.out.println("mono1");

});

Mono<Void> mono2 = Mono.fromRunnable(() -> {

    System.out.println("mono2");

});

Mono<Void> mono3 = Mono.fromRunnable(() -> {

    System.out.println("mono3");

});

两个都:


mono1

        .then(mono2)

        .then(mono3)

        .block();

和:


mono1

        .and(mono2)

        .and(mono3)

        .block();

具有相同的输出:


sleep

mono1

mono2

mono3

在这种情况下Mono#then和之间有什么区别?Mono#and


来自https://projectreactor.io/docs/core/release/reference/index.html#which-operator:


[如果你]有一个序列但[你]对值不感兴趣并且[你]想在最后切换到另一个 Mono,[使用] Mono#then(mono)。


[如果你]想通过协调他们从 1 Mono 和任何源到 Mono 的终止来合并发布者,[使用] Mono#and。


#and不幸的是,这并不能帮助我找到一个#then行为不同的案例。


森林海
浏览 474回答 1
1回答

噜噜哒

Mono#and只是“将来自当前单声道和另一个源的终止信号加入到返回的无效单声道中”。它总是返回Mono<Void>并且只允许你协调两个Monos 的终止。Mono#then允许您将两个Monos 链接在一起,最终结果将由Mono作为参数传递的值确定。从这个意义上说,Mono#then是一个更原始的版本Mono#flatMap,唯一的区别是您可以在链中Mono#flatMap访问前Mono一个的结果,您可以将其转换为另一个Mono实例。除此之外, withMono#then操作将按顺序执行,而 withMono#and不能保证顺序(至少从文档中是这样)。
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java