scala - 如何使用 FS2 在 Scala 中实现递归斐波那契数列？

Question

在尝试熟悉 FS2 时，我遇到了一个使用 Scala 集合的 Stream 的漂亮递归实现，并认为我可以在 FS2 中尝试一下：

  import fs2.{Pure, Stream}
  val fibs: Stream[Pure, Int] = Stream[Pure, Int](0) ++ fibs.fold[Int](1)(_ + _)
  println(fibs take 10 toList) // This will hang

这在 FS2 中挂起的原因是什么，获得类似的有效解决方案的最佳方法是什么？

Answer 1

您的问题是Stream.fold消耗流的所有元素，从折叠中产生一个最终值。请注意，它只发出一个元素。

递归流仅在发出 10 个元素时终止（由 指定take 10）。由于此流的生产力不足，因此fold继续添加价值而不会停止。

解决此问题的最简单方法是使用组合器，该组合器从折叠中发出部分结果；这是scan。

此外，FS2 可以推断此代码中的大多数类型，因此您不一定需要那么多类型注释。

以下实现应该可以正常工作：

import fs2.{Pure, Stream}
val fibs: Stream[Pure, Int] = Stream(0) ++ fibs.scan(1)(_ + _)
println(fibs take 10 toList)