Java Streams Api，有限流[重复]

Question

我试图通过使用Java Streams API创建一个fibonacci序列。我已经创建了一个供应商，但我希望它停止在一个特定的值（例如1000000）。

补充者：

import java.util.function.Supplier;

public class FibonacciSupplier implements Supplier<Integer> {

    private int current;
    private int next;

    public FibonacciSupplier() {
        current = 0;
        next = 1;
    }

    @Override
    public Integer get() {
        int result = current;
        current = next + current;
        next = result;
        return result;
    }
}

我希望它是怎样的：

Stream.generate(new FibonacciSupplier()).maxValue(1000000);

maxValue不是作为函数存在的，我使用它作为上下文的名称。

Answer 1

最好的解决方案是使用TakeWhile，它在Java9+中可用：

Stream.generate(new FibonacciSupplier())
    .takeWhile(i -> i <= 1000000) //will stop stream when value exceeds given limit
    .forEach(System.out::println);

如果您使用的是Java8，那么您可能需要研究阻止无限流的黑客