如何从迭代器创建Java 8 Stream?
问题内容:
是否可以从迭代器创建一个Stream,其中对象的序列与通过重复调用迭代器的next()方法生成的对象的序列相同?我正在考虑的特定情况涉及TreeSet.descendingIterator()返回的迭代器的使用,但是我可以想象在其他情况下可以使用迭代器而不是它引用的集合。
例如,对于a,TreeSet<T> tset
我们可以tset.stream()...
按照集合的排序顺序来编写并获取该集合中的对象流,但是如果我们希望它们以不同的顺序(例如,使用using可以得到)descendingIterator()
呢?我正在想象类似tset.descendingIterator().stream()...
或的东西stream( tset.descendingIterator() )...
,尽管这些形式都不有效。
问题答案:
对于的特定示例NavigableSet.descendingIterator()
,我认为最简单的方法是使用NavigableSet.descendingSet()
。
但是鉴于您可能对更一般的情况感兴趣,因此以下方法似乎可行:
import java.util.Iterator;
import java.util.Spliterator;
import java.util.Spliterators;
import java.util.TreeSet;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
public class Streams {
public static void main(String... args) {
TreeSet<String> set = new TreeSet<>();
set.add("C");
set.add("A");
set.add("B");
Iterator<String> iterator = set.descendingIterator();
int characteristics = Spliterator.DISTINCT | Spliterator.SORTED | Spliterator.ORDERED;
Spliterator<String> spliterator = Spliterators.spliteratorUnknownSize(iterator, characteristics);
boolean parallel = false;
Stream<String> stream = StreamSupport.stream(spliterator, parallel);
stream.forEach(System.out::println); // prints C, then B, then A
}
}
简而言之,您必须使用中的一种静态方法Spliterator
从Iterator
第一个创建一个Spliterators
。然后,您可以Stream
使用中的静态方法创建一个StreamSupport
。
我还没有太多关于手工创建Splitters和Streams的经验,因此我无法真正评论特性应该是什么或它们将产生什么效果。在这个特定的简单示例中,我是否定义了上述特征,或者是否将其设置为0(即没有特征)似乎都没有关系。还有一种Spliterators
用于创建具有初始大小估计值的Spliterator
的方法-
我想在这个特定示例中可以使用set.size()
,但是如果您想处理任意Iterators,我想情况就不会如此。同样,我不太确定它会对性能产生什么影响。