我希望能够在折叠 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]
问问题
99 次
我希望能够在折叠 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]