溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
小編這次要給大家分享的是Java中Stream流怎么實現合并操作，文章內容豐富，感興趣的小伙伴可以來了解一下，希望大家閱讀完這篇文章之后能夠有所收獲。
1. 前言
Java Stream Api 提供了很多有用的 Api 讓我們很方便將集合或者多個同類型的元素轉換為流進行操作。今天我們來看看如何合并 Stream 流。
Stream 流合并的前提是元素的類型能夠一致。
最簡單合并流的方法是通過 Stream.concat() 靜態方法：
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);
這種合并是將兩個流一前一后進行拼接：
多個流的合并我們也可以使用上面的方式進行“套娃操作”：
Stream.concat(Stream.concat(stream, another), more);
你可以一層一層繼續套下去，如果需要合并的流多了，看上去不是很清晰。
我之前介紹過一個Stream 的 flatmap 操作 ，它的大致流程可以參考里面的這一張圖：
因此我們可以通過 flatmap 進行實現合并多個流：
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>> 的流，然后進行 flatmap 平鋪操作合并。
有很多第三方的強化庫 StreamEx 、Jooλ 都可以進行合并操作。另外反應式編程庫 Reactor 3 也可以將 Stream 流合并為反應流，在某些場景下可能會有用。這里演示一下：
List<Integer> block = Flux.fromStream(stream)
.mergeWith(Flux.fromStream(another))
.collectList()
.block();看完這篇關于Java中Stream流怎么實現合并操作的文章，如果覺得文章內容寫得不錯的話，可以把它分享出去給更多人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
