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区别的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了Spring Cloud 覆写远端的配置属性的相关知识，非常不错，具有参考借鉴价值,需要的朋友可以参考下2018-01-01
这篇文章主要介绍了对ThreadLocal内存泄漏及弱引用的理解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-01-01
这篇文章主要介绍了SparkSQL读取hive数据本地idea运行的方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-09-09
本文主要介绍了Java实现二叉搜索树的查找、插入、删除、遍历等内容。具有很好的参考价值，下面跟着小编一起来看下吧2017-02-02
这篇文章主要介绍了spring boot基于注解的声明式事务配置详解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
这篇文章主要为大家详细介绍了javaweb分页的原理，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-04-04
Spring扩展点之BeanFactoryPostProcessor详解
这篇文章主要介绍了Spring扩展点之BeanFactoryPostProcessor详解,Spring的设计非常优雅,有很多的扩展点供我们对项目进行扩展,今天学习一下Spring其中扩展点之一的BeanFactoryPostProcessor,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了Java使用观察者模式实现气象局高温预警功能,结合完整实例形式分析了java观察者模式实现气象局高温预警的相关接口定义、使用、功能操作技巧,并总结了其设计原则与适用场合,具有一定参考借鉴价值,需要的朋友可以参考下2018-04-04
这篇文章主要介绍了springboot项目拦截器重定向循环问题的解决，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-09-09
这篇文章主要为大家详细介绍了java实现从网络下载多个文件，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-07-07
最新评论