Java中的有限生成流--如何创建？

Question

在Java中，可以使用stream.generate(supplier)轻松地生成无限流。但是，我需要生成一个最终完成的流。

想象一下，例如，我想要一个目录中所有文件的流。文件的数量可能很大，因此我无法预先收集所有数据并从中创建流（通过collection.stream())。我需要一段一段地生成序列。但是流显然会在某个时候完成，而像(collection()或findany())这样的终端操作符需要对其进行操作，因此stream.generate(supplier)在这里不合适。

有没有什么合理的简单方法可以在Java中做到这一点，而不用我自己实现整个流接口呢？

我可以想到一个简单的hack--使用无限的stream.generate(supplier)进行操作，并在所有实际值被取走时提供null或抛出异常。但它会破坏标准流运算符,我只能在知道这种行为的自己的运算符中使用它。

澄清

评论中的人建议使用metakewhile()运算符。我不是这个意思。如何更好地表达问题...我不是在问如何过滤（或限制）现有的流，我是在问如何动态地创建（生成）流，而不预先加载所有元素，但是流的大小有限（事先未知）。

解决方案

    Iterator it = myCustomIteratorThatGeneratesTheSequence();
    StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, Spliterator.DISTINCT), false);

Answer 1

有没有什么合理的简单方法可以在Java中做到这一点，而不用我自己实现整个流接口呢？

简单的.limit()保证它将终止。但这并不总是足够强大的。

在stream工厂方法之后，创建海关流源而不重新实现流处理管道的最简单方法是对java.util.Spliterators.AbstractSpliterator 进行子类化，并将其传递给java.util.stream.StreamSupport.stream(Supplier<？extends Spliterator >,int,boolean)

如果您打算使用并行流，请注意abstractspliterator只产生次优的拆分。如果您对源代码有更多的控制，完全实现spliterator接口可以更好地实现。

例如，下面的代码段将创建一个流，提供无限序列1,2,3....

在该特定示例中，您可以使用intStream.range()

像findany()这样的短路操作实际上可以在无限流上完成，只要有任何匹配的元素。

Java9引入了Stream.Iterate来为一些简单的情况生成有限的流。