3

parMapN 関数を使用しようとしていますが、コードをコンパイルできません。私のタイプが IO の場合は問題ありませんが、関数でタイプを使用すると、それを機能させることができません。

以下のスニペットには、正しくコンパイルおよび実行される randomMessage がありますが、スコープに暗黙的な NonEmptyParallel がないため、 randomMessageF の呼び出しはコンパイルされません。しかし、どの暗黙のうちに 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))
      }

    }
4

1 に答える 1

2

試す

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#L834

于 2019-01-10T14:21:26.033 に答える