Изменение типа эффекта fs2.Stream

Я использую 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.


scala functional-programming scala-cats fs2
person Some Name    schedule 13.07.2020    source источник

Ответы (1)


arrow_upward
4
arrow_downward

Метод, который вы ищете, называется _ 1_ или translateInterruptible в некоторых случаях.

person Matthias Berndt    schedule 13.07.2020