温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Java中怎么合并Stream流

发布时间:2021-07-01 15:15:20 来源:亿速云 阅读:260 作者:Leah 栏目:大数据

这篇文章将为大家详细讲解有关Java中怎么合并Stream流,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。


1. 前言

Java Stream Api[1]提供了很多有用的 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);                  
             
 
这种合并是将两个流一前一后进行拼接:  
Java中怎么合并Stream流  
 

2.2 多个流的合并

多个流的合并我们也可以使用上面的方式进行“套娃操作”:  

    
Stream.concat(Stream.concat(stream, another), more);                  
             
 
你可以一层一层继续套下去,如果需要合并的流多了,看上去不是很清晰。  
我之前介绍过一个Stream 的 flatmap 操作[2],它的大致流程可以参考里面的这一张图:  
Java中怎么合并Stream流  
因此我们可以通过   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 第三方库

有很多第三方的强化库StreamExJooλ都可以进行合并操作。另外反应式编程库Reactor 3[3]也可以将Stream流合并为反应流,在某些场景下可能会有用。这里演示一下:  

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

关于Java中怎么合并Stream流就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI