dnet45/modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/util/StreamUtils.java @ 57509
1 | 52935 | claudio.at | package eu.dnetlib.data.mapreduce.util; |
---|---|---|---|
2 | |||
3 | import java.util.Iterator; |
||
4 | import java.util.Spliterator; |
||
5 | import java.util.Spliterators; |
||
6 | import java.util.stream.Stream; |
||
7 | import java.util.stream.StreamSupport; |
||
8 | |||
9 | public class StreamUtils { |
||
10 | |||
11 | public static <T> Stream<T> toStream(final Iterator<T> it) { |
||
12 | return StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, Spliterator.ORDERED), false); |
||
13 | }
|
||
14 | |||
15 | }
|