流化迭代器的最简单方法

Question

假设您希望对迭代器的元素进行流式处理；让我们使用一个扫描器的具体示例，它实现了迭代器 。

给定迭代器,比方说：

// Scanner implements Iterator<String>
Iterator<String> scanner = new Scanner(System.in);

StreamSupport.stream(
  Spliterators.spliteratorUnknownSize(scanner, Spliterator.ORDERED), false);

 StreamSupport.stream(
  ((Iterable<String>) () -> new Scanner(System.in)).spliterator(), false);

在给定迭代器 的情况下，JDK中是否有一个工厂方法返回流 ？

Answer 1

我只需要使用stream.generate(iterator::next)。是的，它是一个无限流，但是system.in中的扫描器也是如此，除非您知道您需要多少行，在这种情况下，它很容易使用

Stream.generate(iterator::next).limit(numLines);

这可以防止迭代器被迭代两次（一次作为迭代器，一次作为流）。

如果您需要一个有大小的流而不知道它会有多大，但又不想弄乱您的代码，只需创建一个显式地接受可迭代 的实用程序方法：

public static <T> Stream<T> stream(Iterable<T> it){
    return StreamSupport.stream(it.spliterator(), false);
}  

它最终会比试图将其全部塞在一行中更易读，然后您就可以调用Stream(()->Iterator)；或Stream(()->New Scanner(system.in))；

您也可以很容易地添加第二个方便方法：

public static <T> Stream<T> stream(Iterator<T> it){
    return stream(()->it);
}

使您能够调用流（迭代器）；或流（新扫描程序（System.in））；

但是，如果我要将system.in读取到流中，我可能会使用读取器而不是扫描器：

return new BufferedReader(new InputStreamReader(System.in)).lines();