spring-boot - 我可以在运行时停止 Flux.range 吗？

Question

在 Flux.range 中按照以下方法从 1 运行到 100 时，它会根据条件询问是否可以像“For 语句”一样完成。

Flux.range(0,100).map { number ->
            if (number > 10)
                // break; --> is possible?
        }

标签： spring-bootkotlinspring-webfluxproject-reactor

Answer 1

您可以takeWhile为此目的使用运算符：

Flux.range(0,100).takeWhile { it <= 10 }