Reactor3 Map與FlatMap的區(qū)別示例詳解
Publisher Map 與 FlatMap的區(qū)別
環(huán)境信息:
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);同步的轉(zhuǎn)換發(fā)布的元素并返回。
1.2 flatMap()
Flux<String> monoFlatMap = Mono.just("1").flatMap(a -> Mono.just(a + "1"));
monoFlatMap.subscribe(System.out::println);異步的轉(zhuǎn)換發(fā)布的元素并返回一個新的Mono,被轉(zhuǎn)換的元素和新Mono是動態(tài)綁定的。
2 Flux
2.1 map()
Mono<String> fluxMap = Flux.just("1").map(a -> a + "1");
fluxMap.subscribe(System.out::println);同步的轉(zhuǎn)換發(fā)布的元素并返回,轉(zhuǎn)換完后被轉(zhuǎn)換元素被丟棄。
2.2 flatMap()
Flux<String> fluxFlatMap = Flux.just("1").flatMap(a -> Flux.just(a + "1"));
fluxFlatMap.subscribe(System.out::println);異步的轉(zhuǎn)換發(fā)布的元素并他們展開合并到一個新的Flux并返回。
以上就是Reactor3 Map與FlatMap的區(qū)別示例詳解的詳細內(nèi)容,更多關(guān)于Reactor3 Map FlatMap區(qū)別的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Java中的notyfy()和notifyAll()的本質(zhì)區(qū)別
很多朋友對java中的notyfy()和notifyAll()的本質(zhì)區(qū)別不了解,今天小編抽空給大家整理一篇教程關(guān)于Java中的notyfy()和notifyAll()的本質(zhì)區(qū)別,需要的朋友參考下吧2017-02-02
spring boot + mybatis如何實現(xiàn)數(shù)據(jù)庫的讀寫分離
這篇文章主要給大家介紹了關(guān)于spring boot + mybatis如何實現(xiàn)數(shù)據(jù)庫的讀寫分離的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家學習或者使用spring boot具有一定的參考學習價值,需要的朋友們下面來一起學習學習吧2019-09-09
DOM解析XML報錯Content is not allowed in prolog解決方案詳解
這篇文章主要介紹了DOM解析XML報錯解決方案詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-10-10
java算法導(dǎo)論之FloydWarshall算法實現(xiàn)代碼
這篇文章主要介紹了算法導(dǎo)論之FloydWarshall算法實現(xiàn)代碼的相關(guān)資料,需要的朋友可以參考下2017-05-05
SpringBoot如何處理@KafkaListener消息
Spring通過KafkaMessageListenerContainer、ConcurrentMessageListenerContainer等組件實現(xiàn)Kafka消息的監(jiān)聽和處理,并通過@KafkaListener注解將業(yè)務(wù)邏輯與Kafka消費者連接起來,Spring?Boot自動配置Kafka相關(guān)組件,簡化了Kafka的使用2024-12-12
JAVA內(nèi)存模型和Happens-Before規(guī)則知識點講解
在本篇文章里小編給大家整理的是一篇關(guān)于JAVA內(nèi)存模型和Happens-Before規(guī)則知識點內(nèi)容,有需要的朋友們跟著學習下。2020-11-11

