如何从迭代器创建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
    }
}

简而言之,您必须使用中的一种静态方法SpliteratorIterator第一个创建一个Spliterators。然后,您可以Stream使用中的静态方法创建一个StreamSupport

我还没有太多关于手工创建Splitters和Streams的经验,因此我无法真正评论特性应该是什么或它们将产生什么效果。在这个特定的简单示例中,我是否定义了上述特征,或者是否将其设置为0(即没有特征)似乎都没有关系。还有一种Spliterators用于创建具有初始大小估计值的Spliterator
的方法-
我想在这个特定示例中可以使用set.size(),但是如果您想处理任意Iterators,我想情况就不会如此。同样,我不太确定它会对性能产生什么影响。