3

我正在尝试使用 parMapN 函数，但无法编译代码。如果我的类型是 IO 那么没有问题，但是当我在我的函数上使用类型时，我无法让它工作。

在下面的代码片段中，有 randomMessage 可以正确编译和运行，但调用 randomMessageF 不会编译，因为范围上没有隐式 NonEmptyParallel。但是，哪个隐式正在使用 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 回答