请考虑以下示例:
import cats.Functor
import cats.effect.{Concurrent, Timer}
import cats.syntax.functor._
import fs2.Stream
import scala.concurrent.duration._
class FetchAndSum[F[_]: Timer: Concurrent: Functor](fetch: List[String] => F[List[Int]]) {
def run(inputs: List[String]): F[Int] =
Stream
.emits(inputs)
.covary[F]
.groupWithin(20, 10.millis)
.mapAsync(10)(chunk => fetch(chunk.toList))
.flatMap(Stream.emits)
.reduce(_ + _)
.compile
.last
.map(_.getOrElse(0))
}
在生产中,这是用IO
Monad实例化的。
在我的测试中,我想测试调用fetch
函数的次数。如果F[_]
只需要一个Functor
实例,我可以简单地使用 Writer
monad 来做到这一点。
由于 fs2 的mapAsync
和groupedWithin
,F[_]
还必须有 Timer
和 Concurrent
的实例,这些实例当然在 Writer
上不存在。
我可以使用什么数据类型以功能方式对此进行测试?
我想以某种方式将IO
与Writer
结合起来,例如 type IOWriter[A] = IO[Writer[Int, A]]
,但是如果不重新声明IOWriter
的所有类型类实例,我就无法完成这项工作。
是否有某些东西可以让我实现这一点而不必重新声明所有类型类实例?
将IO
与Ref
一起使用:
val numsExecuted: IO[Int] = for {
ref <- Ref[IO].of(0)
fetch = (l: List[String]) => ref.update(_ + 1).as(???)
_ <- new FetchAndSum[IO](fetch).run(???)
x <- ref.get
} yield x
您还可以将Writer
与IO
结合使用。这种构造被称为写入器单体转换器(type IOWriter[A] = cats.data.WriterT[IO, A]
),并且应该具有开箱即用的并发/计时器/单体/等实例。