更改 fs2.Stream 的效果类型

Som*_*ame 3 functional-programming scala scala-cats fs2

我正在使用 doobie,它可以生成fs2.Stream[ConnectionIO, Int]数据库行(Int在我的例子中)。这ConnectionIO[A]是 doobie 的内部类型。

给定了 HKT F[_]val nt: ConnectionIO ~> F有什么办法可以到达fs2.Stream[F, Int]fs2.Stream[ConnectionIO, Int]

我没有找到某种mapK定义的fs2.Stream.

Mat*_*ndt 5

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