Reactor3 Map 与 FlatMap的区别

我不是女神ヾ 2021-09-29 06:34 357阅读 0赞

# 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并返回。

发表评论取消回复

表情：

评论列表（有 0 条评论，357人围观）

还没有评论，来说两句吧...

相关阅读

相关 java8中的map与flatmap

问题假如我们有这样一个需求给定单词列表\["Hello","World"\]，你想要返回列表\["H","e","l", "o","W","r","d"\],如果我们使

朱雀/ 2022年12月27日 01:20/ 0 赞/ 136 阅读

相关 Spring Reactor map与flatMap操作符详解

上一篇：[Spring Reactor 操作符详解][Spring Reactor] 中讲了创建类与时间类操作符； [第三篇：Spring Reactor parallel

傷城~/ 2022年12月25日 10:54/ 0 赞/ 203 阅读

相关 map和flatMap

map比较简单，一生一，可以抽取列表元素的某个属性形成新的列表 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow

清疚/ 2022年11月13日 06:28/ 0 赞/ 181 阅读

相关 Spark 中 map 与 flatMap 的区别

转载地址：[http://www.bkjia.com/yjs/927704.html][http_www.bkjia.com_yjs_927704.html] 通过一个实验来

向右看齐/ 2022年09月22日 12:58/ 0 赞/ 174 阅读

相关 Spark之中map与flatMap的区别

Spark之中map与flatMap的区别一直不太明白spark之中map与flatMap之间的区别。map的作用很容易理解就是对rdd之中的元素进行逐一进行函数操作映

灰太狼/ 2022年08月21日 05:44/ 0 赞/ 247 阅读

相关 JAVA8 - Optional中map和flatMap的区别

map中获取的返回值自动被Optional包装,即返回值 -> Optional<返回值> flatMap中返回值保持不变,但必须是Optional类型,即Optional<

深藏阁楼爱情的钟/ 2022年05月20日 02:28/ 0 赞/ 379 阅读

相关 Stream流中间操作之map和flatMap的区别

可以这么说，Stream流几乎可以完成对集合的任意操作，过滤、限流、跳过、映射、排序、分组等下面讲一下其中比较难理解的两个映射操作map和flatMap的区别推荐直

秒速五厘米/ 2022年01月17日 07:23/ 0 赞/ 261 阅读

相关 map和flatmap的区别

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][] map函数会对每一条输入进行指定的操作，然后为每一条输入返回一个对象；而flatMap

缺乏、安全感/ 2022年01月15日 07:29/ 0 赞/ 250 阅读

相关 Reactor3 Map 与 FlatMap的区别

Publisher Map 与 FlatMap的区别环境信息： JDK: Java 8 Reactor: Reactor 3.2.10.RELEASE Gra

我不是女神ヾ/ 2021年09月29日 06:34/ 0 赞/ 358 阅读

相关 java8 map flatmap

[https://www.cnblogs.com/diegodu/p/8794857.html][https_www.cnblogs.com_diegodu_p_8794857

川长思鸟来/ 2021年06月11日 15:14/ 0 赞/ 531 阅读