Где найти кота. Незаполненный Параллель [IO, F]? - PullRequest
0 голосов
/ 08 сентября 2018

Это раньше работало:

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]), чтобы это снова заработало? Спасибо.

1 Ответ

0 голосов
/ 08 сентября 2018

Поскольку RC3 , для параллельного экземпляра ввода-вывода требуется ContextShift[IO] неявное вместо Timer[IO].

Вы можете получить один из IOApp или набрав IO.contextShift(ec), где ec равно scala.concurrent.ExecutionContext

...