Reactor3 Map與FlatMap的區(qū)別示例詳解
更新時間：2023年08月23日 17:31:59 作者：Weison Wei
這篇文章主要為大家介紹了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基礎之TreeMap實現(xiàn)類全面詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-12-12
最近學習Java，在處理XML文檔的時候，查閱相關資料，發(fā)現(xiàn)了DOM4J這個jre庫，相對C#的XML處理來說，功能還算是跟得2013-09-09
在Spring Boot中,starter是一種特殊的依賴,它可以幫助開發(fā)人員快速引入和配置某個特定的功能模塊,我們在面試中通過會被問到SpringBoot3如何自定義starter,所以本文小編給大家詳細介紹了SpringBoot3自定義starter的步驟,需要的朋友可以參考下2024-09-09
這篇文章主要介紹了JAVA 對象創(chuàng)建與對象克隆，new 創(chuàng)建、反射、克隆、反序列化，克隆它分為深拷貝和淺拷貝，通過調用對象的 clone方法，進行對象的克隆，下面來看看文章的詳細內容吧2022-02-02
Windows中使用Java生成Excel文件并插入圖片的方法
這篇文章主要介紹了Windows中使用Java生成Excel文件并插入圖片的方法,其中向Excel中插入圖片文中通過使用Apache POI來實現(xiàn),需要的朋友可以參考下2016-02-02
文章介紹了在集成Spring和Nutz時處理事務管理的幾種方式,包括手動管理、Spring聲明式事務管理以及將事務交給Spring管理的方法2026-02-02
長輪詢是與服務器保持即時通信的最簡單的方式，它不使用任何特定的協(xié)議，例如 WebSocket ，所以也不依賴于瀏覽器版本等外部條件的兼容性。本文將用Java實現(xiàn)一個簡單的長輪詢，需要的可以參考一下2022-08-08
在我們線上環(huán)境中，一般不會開啟debug級別的日志，為了提高性能?info和warning級別的日志也一般不會打印出來，那么如果遇到線上問題，除了使用arthas定位問題，想通過查詢日志來實現(xiàn)問題定位，如何查看logger信息，更新logger?level呢，下面我們來了解arthas修改日志級別2022-06-06
代理模式（Proxy Parttern）為一個對象提供一個替身，來控制這個對象的訪問，即通過代理對象來訪問目標對象。本文將通過示例詳細講解一下這個模式，需要的可以參考一下2022-11-11
這篇文章主要介紹了Java編程泛型限定的相關內容，具有一定參考價值，需要的朋友可以了解下。2017-10-10