Reactor3 Map 与 FlatMap的区别

我不是女神ヾ 2021-09-29 06:34 371阅读 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 条评论，371人围观）

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

相关阅读

相关 map 和 flatMap 的区别

一、map 和 flatMap 对应的源码 ① map方法 <R> Stream<R> map(Function<? super T, ? extends

川长思鸟来/ 2024年03月27日 14:59/ 0 赞/ 101 阅读

相关 java8中的map与flatmap区别

map:只能返回一个值 flatmap:返回多个值 new ArrayList().stream().map(x -> x);//返回一个 new ArrayList(

偏执的太偏执、/ 2023年10月01日 08:51/ 0 赞/ 15 阅读

相关 java8中的map与flatmap

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

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

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

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

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

相关 java8 map()和flatMap()之间的区别

1.概述 map()和flatMap() 在Java 8中，可以在Optional，Stream和CompletableFuture中找到它们（尽管名称稍有不同）。流

爱被打了一巴掌/ 2022年11月15日 11:41/ 0 赞/ 14 阅读

相关 map和flatMap

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

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

相关 Spark 中 map 与 flatMap 的区别

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

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

相关 Spark之中map与flatMap的区别

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

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

相关 map和flatmap的区别

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

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

相关 Reactor3 Map 与 FlatMap的区别

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

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