1. 前言

Java Stream Api 提供了很多有用的 Api 讓我們很方便將集合或者多個(gè)同類型的元素轉(zhuǎn)換為流進(jìn)行操作。今天我們來看看如何合并 Stream 流。

2. Stream 流的合并

Stream 流合并的前提是元素的類型能夠一致。

2.1 concat

最簡(jiǎn)單合并流的方法是通過 Stream.concat() 靜態(tài)方法：

Stream stream = Stream.of(1, 2, 3);

Stream another = Stream.of(4, 5, 6);

Stream concat = Stream.concat(stream, another);

List collect = concat.collect(Collectors.toList());

List expected = Lists.list(1, 2, 3, 4, 5, 6);

Assertions.assertIterableEquals(expected, collect);

這種合并是將兩個(gè)流一前一后進(jìn)行拼接：

2.2 多個(gè)流的合并

多個(gè)流的合并我們也可以使用上面的方式進(jìn)行“套娃操作”：

Stream.concat(Stream.concat(stream, another), more);

你可以一層一層繼續(xù)套下去，如果需要合并的流多了，看上去不是很清晰。

我之前介紹過一個(gè)Stream 的 flatmap 操作 ，它的大致流程可以參考里面的這一張圖：

因此我們可以通過 flatmap 進(jìn)行實(shí)現(xiàn)合并多個(gè)流：

Stream stream = Stream.of(1, 2, 3);

Stream another = Stream.of(4, 5, 6);

Stream third = Stream.of(7, 8, 9);

Stream more = Stream.of(0);

Stream concat = Stream.of(stream,another,third,more).

flatMap(integerStream -> integerStream);

List collect = concat.collect(Collectors.toList());

List expected = Lists.list(1, 2, 3, 4, 5, 6, 7, 8, 9, 0);

Assertions.assertIterableEquals(expected, collect);

這種方式是先將多個(gè)流作為元素生成一個(gè)類型為 Stream> 的流，然后進(jìn)行 flatmap 平鋪操作合并。

2.3 第三方庫

有很多第三方的強(qiáng)化庫 StreamEx 、Jooλ 都可以進(jìn)行合并操作。另外反應(yīng)式編程庫 Reactor 3 也可以將 Stream 流合并為反應(yīng)流，在某些場(chǎng)景下可能會(huì)有用。這里演示一下：

List block = Flux.fromStream(stream)

.mergeWith(Flux.fromStream(another))

.collectList()

.block();

3. 總結(jié)

如果你經(jīng)常使用 Java Stream Api ，合并 Stream 流是經(jīng)常遇到的操作。今天簡(jiǎn)單介紹了合并 Stream 流的方式，希望對(duì)你有用。我是 碼農(nóng)小胖哥 ,多多關(guān)注！更多干貨奉上。

關(guān)注微信公眾號(hào)：Felordcn 獲取更多干貨

總結(jié)

以上是生活随笔為你收集整理的java 两个stream合并_Java Stream 流如何进行合并操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。