首页 > 软件编程 > java > Reactor3 Map FlatMap区别

Reactor3 Map与FlatMap的区别示例详解

2023-08-23 17:31:59 作者：Weison Wei

这篇文章主要为大家介绍了Reactor3 Map与FlatMap的区别示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

Publisher Map 与 FlatMap的区别

环境信息：

JDK: Java 8
Reactor: Reactor 3.2.10.RELEASE

Gradle依赖：

compile group: 'io.projectreactor', name: 'reactor-core', version: '3.2.10.RELEASE'
compile 'ch.qos.logback:logback-classic:1.2.1'
testCompile 'io.projectreactor.addons:reactor-test'
testCompile 'junit:junit:4.12'

这几个代码的效果都一样，打印出11;

Mono.just("1").map(a -> a + "1").subscribe(System.out::println);
Mono.just("1").flatMap(a -> Mono.just(a + "1")).subscribe(System.out::println);
Flux.just("1").map(a -> a + "1").subscribe(System.out::println);
Flux.just("1").flatMap(a -> Flux.just(a + "1")).subscribe(System.out::println);

1 Mono

1.1 map()

Mono<String> monoMap = Mono.just("1").map(a -> a + "1");
monoMap.subscribe(System.out::println);

同步的转换发布的元素并返回。

1.2 flatMap()

Flux<String> monoFlatMap = Mono.just("1").flatMap(a -> Mono.just(a + "1"));
monoFlatMap.subscribe(System.out::println);

异步的转换发布的元素并返回一个新的Mono，被转换的元素和新Mono是动态绑定的。

2 Flux

2.1 map()

Mono<String> fluxMap = Flux.just("1").map(a -> a + "1");
fluxMap.subscribe(System.out::println);

同步的转换发布的元素并返回，转换完后被转换元素被丢弃。

2.2 flatMap()

Flux<String> fluxFlatMap = Flux.just("1").flatMap(a -> Flux.just(a + "1"));
fluxFlatMap.subscribe(System.out::println);

异步的转换发布的元素并他们展开合并到一个新的Flux并返回。

以上就是Reactor3 Map与FlatMap的区别示例详解的详细内容，更多关于Reactor3 Map FlatMap区别的资料请关注脚本之家其它相关文章！