Java Stream 流如何进行合并操作
JAVA 如何 操作 进行 合并 stream
2023-09-11 14:18:43 时间
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 获取更多资讯
相关文章
- 秒懂+史上最全:JVM进程、Java进程的用户空间与内核空间如何区分? 如何区分Java进程的内核态与用户态?
- Java本地远程断点调试(实战记录)
- Java: sourcepath classpath
- 使用exe4j把java程序生成可执行的.exe文件
- Strange java.lang.ArrayIndexOutOfBoundsException thrown on jetty startup
- 如何构建自己的Java学习体系?
- Java HashMap 如何正确遍历并删除元素
- Java - CentOS下JDK的安装教程(及JAVA_HOME配置、以jdk1.8为例)
- 【Java】Eclipse如何创建java项目并运行
- 【FAQ】【JAVA UI】HarmonyOS 如何获取uid和pid
- 如何在Java Filter 中注入 Service
- 《21天学通Java(第6版)》—— 2.3 注释
- 大数据学习——JAVA采集程序
- Java中的Import语句如何理解?
- 万字长文深入理解java中的集合-附PDF下载
- java的注解学习
- 浅析js前端如何将word文档转为html:docx是怎样存储图片的、Java使用POI如何实现、前端使用Mammoth.js如何实现
- 【转】Java学习---快速掌握RPC原理及实现
- Java中的set集合如何理解(三)——精简
- Java操作Mongodb 保存/读取java对象到/从mongodb
- 从头认识java-13.12 超类通配符
- 浅谈如何用Java操作MongoDB?
- JAVA如何设置代理server,s取消代理erver
- 如何编写良好的Java代码?为什么?
- java fileupload上传附件到服务器,可携带参数(简单易用)可跨域,看这篇就够了
- Java实现两个文件内容对比
- Java 报错 Information:java: javacTask: 源发行版 8 需要目标发行版 1.8
- Java简单使用EasyExcel操作读写excel
- Java中java.util.Arrays参考指南
- 【Java I/O 流】文件的操作——java.io.File 类详解