Java Stream 流如何進行合併操做

1. 前言

Java Stream Api 提供了不少有用的 Api 讓咱們很方便將集合或者多個同類型的元素轉換爲流進行操做。今天咱們來看看如何合併 Stream 流。

2. Stream 流的合併

Stream 流合併的前提是元素的類型可以一致。

2.1 concat

最簡單合併流的方法是經過 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);
複製代碼

這種合併是將兩個流一前一後進行拼接：

2.2 多個流的合併

多個流的合併咱們也可使用上面的方式進行「套娃操做」：

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 平鋪操做合併。

2.3 第三方庫

有不少第三方的強化庫 StreamEx 、Jooλ 均可以進行合併操做。另外反應式編程庫 Reactor 3 也能夠將 Stream 流合併爲反應流，在某些場景下可能會有用。這裏演示一下：

List<Integer> block = Flux.fromStream(stream)
                       .mergeWith(Flux.fromStream(another))
                                 .collectList()
                                 .block();
複製代碼

3. 總結

若是你常常使用 Java Stream Api ，合併 Stream 流是常常遇到的操做。今天簡單介紹了合併 Stream 流的方式，但願對你有用。我是 碼農小胖哥 ,多多關注！更多幹貨奉上。

關注公衆號：Felordcn獲取更多資訊

我的博客：https://felord.cn