这在过去是有效的:
val ioA = IO(...)
val ioB = IO(...)
val ioC = IO(...)
(ioA, ioB, ioC).parMapN((_, _, _) => ())
然后,在大约或大约猫的1.0.0-RC2
,它停止工作。现在我得到了
could not find implicit value for parameter p: cats.NonEmptyParallel[cats.effect.IO,F]
我就是想不出我需要什么才能让它再次工作。有没有人知道我需要导入或传入什么(我已经尝试了隐式Timer[IO]
)才能让它重新启动并运行?谢谢。
发布于 2018-09-08 16:10:36
从RC3开始,IO的并行实例是requires a ContextShift[IO]
implicit而不是Timer[IO]
。
您可以从IOApp
或通过执行IO.contextShift(ec)
来获取,其中ec
是scala.concurrent.ExecutionContext
https://stackoverflow.com/questions/52231492
复制相似问题