Эффект кошки: как получить неявный NonEmptyParallel

Question

Я пытаюсь использовать функцию parMapN, и я не могу скомпилировать код. Если у меня тип IO, то проблем нет, но когда я использую типы в своих функциях, мне не удается заставить его работать.

В приведенном ниже фрагменте есть randomMessage, который компилируется и выполняется правильно, но вызов randomMessageF не компилируется, так как в области видимости не существует не EEmptyParallel. Но тогда какой неявный использует randomMessage? Передача contextShift также не работает.

    import cats.NonEmptyParallel
    import cats.effect._
    import cats.syntax.all._
    import fs2._

    import scala.util.Random

    object Test  extends IOApp {

      def randomMessageF[F[_], A, B, C](toA: => F[A],
                                       toB: => F[B],
                                       toC: (A, B) => C)(implicit nep: NonEmptyParallel[F, F]): Stream[F, C] = Stream.eval {
        val funcA   = toA
        val funcB = toB
        (funcA, funcB).parMapN {
          case (a, b) =>
            toC(a, b)
        }
      }

      def randomMessage[A, B, C](toA: => IO[A],
                                 toB: => IO[B],
                                 toC: (A, B) => C): Stream[IO, C] = Stream.eval {
        val funcA   = toA
        val funcB = toB
        (funcA, funcB).parMapN {
          case (a, b) =>
            toC(a, b)
        }
      }

      def run(args: List[String]): IO[ExitCode] =  {
        println(
          randomMessage(
            IO(Random.nextInt(1000).toString),
            IO(Random.nextString(10)),
            (k: String, v: String) => s"$k:$v"
          ).compile.toList.unsafeRunSync().head)


        println(
          randomMessageF[IO, String, String, String](
            IO(Random.nextInt(1000).toString),
            IO(Random.nextString(10)),
            (k, v) => s"$k:$v"
          )(???).compile.toList.unsafeRunSync().head)

        IO(ExitCode(0))
      }

    }

Answer 1

Пытаться

def randomMessageF[M[_], F[_], A, B, C](toA: => M[A],
                                        toB: => M[B],
                                        toC: (A, B) => C)(implicit 
                                        nep: NonEmptyParallel[M, F]): Stream[M, C] = Stream.eval {
  val funcA = toA
  val funcB = toB
  (funcA, funcB).parMapN {
    case (a, b) =>
      toC(a, b)
  }
}

println(
  randomMessageF/*[IO, IO.Par, String, String, String]*/(
    IO(Random.nextInt(1000).toString),
    IO(Random.nextString(10)),
    (k: String, v: String) => s"$k:$v"
  ).compile.toList.unsafeRunSync().head)

В randomMessage неявное используется NonEmptyParallel[IO, IO.Par],

https://github.com/typelevel/cats-effect/blob/master/core/shared/src/main/scala/cats/effect/IO.scala