首页 > 解决方案 > 在哪里可以找到cats.NonEmptyParallel[IO,F]?

问题描述

这曾经有效:

val ioA = IO(...)
val ioB = IO(...)
val ioC = IO(...)
(ioA, ioB, ioC).parMapN((_, _, _) => ())

然后,在 Cats 附近或附近1.0.0-RC2,它停止了工作。现在我明白了

could not find implicit value for parameter p: cats.NonEmptyParallel[cats.effect.IO,F]

而且我无法弄清楚我需要什么才能让它再次工作。有谁知道我需要导入或传递什么(我尝试过隐式Timer[IO])才能让它恢复运行?谢谢。

标签: scalascala-cats

解决方案


RC3开始,并行 IO 实例需要一个ContextShift[IO]隐式而不是Timer[IO].

你可以从IOApp或通过做得到一个,在IO.contextShift(ec)哪里ecscala.concurrent.ExecutionContext


推荐阅读