我想附加到Stream
但是下一个流依赖于 previousStream
的折叠结果
这是我的做法,但 Streams
被评估了两次
import fs2._
def ints(start: Int) = Stream.iterate(start) { i =>
println(i)
i + 1
}.take(10)
val s = ints(0)
def foldAppend(init: Int)(f: (Int, Int) => Int)(next: Int => Stream[Pure, Int]) = {
s ++ s.fold(init)(f).flatMap(next)
}
val res = foldAppend(0)((s, i) => s + 1)(ints)
println(res.toList)
我怎样才能实现只评估一次的foldAppend
方法。s