小編這次要給大家分享的是Java中Stream流怎么實(shí)現(xiàn)合并操作,文章內(nèi)容豐富,感興趣的小伙伴可以來了解一下,希望大家閱讀完這篇文章之后能夠有所收獲。
創(chuàng)新互聯(lián)公司是專業(yè)的固始網(wǎng)站建設(shè)公司,固始接單;提供網(wǎng)站設(shè)計、做網(wǎng)站,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行固始網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來合作!
1. 前言
Java Stream Api 提供了很多有用的 Api 讓我們很方便將集合或者多個同類型的元素轉(zhuǎn)換為流進(jìn)行操作。今天我們來看看如何合并 Stream 流。
Stream 流合并的前提是元素的類型能夠一致。
最簡單合并流的方法是通過 Stream.concat() 靜態(tài)方法:
Stream<Integer> stream = Stream.of(1, 2, 3); Stream<Integer> another = Stream.of(4, 5, 6); Stream<Integer> concat = Stream.concat(stream, another); List<Integer> collect = concat.collect(Collectors.toList()); List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6); Assertions.assertIterableEquals(expected, collect);
這種合并是將兩個流一前一后進(jìn)行拼接:
多個流的合并我們也可以使用上面的方式進(jìn)行“套娃操作”:
Stream.concat(Stream.concat(stream, another), more);
你可以一層一層繼續(xù)套下去,如果需要合并的流多了,看上去不是很清晰。
我之前介紹過一個Stream 的 flatmap 操作 ,它的大致流程可以參考里面的這一張圖:
因此我們可以通過 flatmap 進(jìn)行實(shí)現(xiàn)合并多個流:
Stream<Integer> stream = Stream.of(1, 2, 3); Stream<Integer> another = Stream.of(4, 5, 6); Stream<Integer> third = Stream.of(7, 8, 9); Stream<Integer> more = Stream.of(0); Stream<Integer> concat = Stream.of(stream,another,third,more). flatMap(integerStream -> integerStream); List<Integer> collect = concat.collect(Collectors.toList()); List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6, 7, 8, 9, 0); Assertions.assertIterableEquals(expected, collect);
這種方式是先將多個流作為元素生成一個類型為 Stream<Stream<T>> 的流,然后進(jìn)行 flatmap 平鋪操作合并。
有很多第三方的強(qiáng)化庫 StreamEx 、Jooλ 都可以進(jìn)行合并操作。另外反應(yīng)式編程庫 Reactor 3 也可以將 Stream 流合并為反應(yīng)流,在某些場景下可能會有用。這里演示一下:
List<Integer> block = Flux.fromStream(stream) .mergeWith(Flux.fromStream(another)) .collectList() .block();
看完這篇關(guān)于Java中Stream流怎么實(shí)現(xiàn)合并操作的文章,如果覺得文章內(nèi)容寫得不錯的話,可以把它分享出去給更多人看到。
網(wǎng)站名稱:Java中Stream流怎么實(shí)現(xiàn)合并操作
文章路徑:http://bm7419.com/article16/pdhgdg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供軟件開發(fā)、面包屑導(dǎo)航、網(wǎng)站營銷、標(biāo)簽優(yōu)化、商城網(wǎng)站、品牌網(wǎng)站設(shè)計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)