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