scala - 改变 fs2.Stream 的效果类型

Question

我正在使用可以生成fs2.Stream[ConnectionIO, Int]数据库行的 doobie（Int在我的情况下）。这ConnectionIO[A]是 doobie 的内部类型。

给定一个HKT F[_]，val nt: ConnectionIO ~> F有没有办法fs2.Stream[F, Int]从fs2.Stream[ConnectionIO, Int]？

我没有找到某种mapK为fs2.Stream.

Answer 1

您正在寻找的方法称为translate，或translateInterruptible在某些情况下。