我希望能够评估每一步,同时折叠一个fs2流。
Stream.iterable[F, Int](List(1, 2, 3, 4, 5))
.evalFold(0){ case (acc, e) => logger.info(acc + e).as(acc + e) }你知道做这件事的方法吗?你能写一个帮助器函数,由来自Stream的函数的组合组成吗?
假设logger.info()为Int => F[Unit]
发布于 2021-01-05 01:20:21
我在fs2 gitter上得到了答案
我既可以使用evalScan(..).last
evalScan并将其调整为仅在end
中输出,来编写evalFold
https://stackoverflow.com/questions/65566520
复制相似问题