diff --git a/core/src/main/scala/cats/data/IorT.scala b/core/src/main/scala/cats/data/IorT.scala index 01285647ba..e36dc7a97a 100644 --- a/core/src/main/scala/cats/data/IorT.scala +++ b/core/src/main/scala/cats/data/IorT.scala @@ -1,6 +1,7 @@ package cats package data +import cats.arrow.FunctionK import cats.syntax.either._ import cats.syntax.option._ @@ -426,6 +427,27 @@ private[data] abstract class IorTInstances1 extends IorTInstances2 { val A0: Semigroup[A] = A val F0: Monad[F] = F } + + implicit def parallelForIorT[F[_], E] + (implicit F: Monad[F], E: Semigroup[E]): Parallel[IorT[F, E, ?], IorT[F, E, ?]] = new Parallel[IorT[F, E, ?], IorT[F, E, ?]] + { + + private[this] val identityK: IorT[F, E, ?] ~> IorT[F, E, ?] = FunctionK.id + private[this] val underlyingParallel: Parallel[Ior[E, ?], Ior[E, ?]] = + Parallel[Ior[E, ?], Ior[E, ?]] + + def parallel: IorT[F, E, ?] ~> IorT[F, E, ?] = identityK + def sequential: IorT[F, E, ?] ~> IorT[F, E, ?] = identityK + + val applicative: Applicative[IorT[F, E, ?]] = new Applicative[IorT[F, E, ?]] { + def pure[A](a: A): IorT[F, E, A] = IorT.pure(a) + def ap[A, B](ff: IorT[F, E, A => B])(fa: IorT[F, E, A]): IorT[F, E, B] = + IorT(F.map2(ff.value, fa.value)((f, a) => underlyingParallel.applicative.ap(f)(a))) + } + + lazy val monad: Monad[IorT[F, E, ?]] = Monad[IorT[F, E, ?]] + } + } private[data] abstract class IorTInstances2 extends IorTInstances3 { diff --git a/tests/src/test/scala/cats/tests/ParallelSuite.scala b/tests/src/test/scala/cats/tests/ParallelSuite.scala index 69861e9aa7..844431ff25 100644 --- a/tests/src/test/scala/cats/tests/ParallelSuite.scala +++ b/tests/src/test/scala/cats/tests/ParallelSuite.scala @@ -171,6 +171,7 @@ class ParallelSuite extends CatsSuite with ApplicativeErrorForEitherTest { checkAll("Parallel[Either[String, ?], Validated[String, ?]]", ParallelTests[Either[String, ?], Validated[String, ?]].parallel[Int, String]) checkAll("Parallel[Ior[String, ?], Ior[String, ?]]", ParallelTests[Ior[String, ?], Ior[String, ?]].parallel[Int, String]) + checkAll("Parallel[IorT[F, String, ?], IorT[F, String, ?]]", ParallelTests[IorT[Option, String, ?], IorT[Option, String, ?]].parallel[Int, String]) checkAll("Parallel[OptionT[M, ?], Nested[F, Option, ?]]", ParallelTests[OptionT[Either[String, ?], ?], Nested[Validated[String, ?], Option, ?]].parallel[Int, String]) checkAll("Parallel[EitherT[M, String, ?], Nested[F, Validated[String, ?], ?]]", ParallelTests[EitherT[Either[String, ?], String, ?], Nested[Validated[String, ?], Validated[String, ?], ?]].parallel[Int, String]) checkAll("Parallel[EitherT[Option, String, ?], Nested[Option, Validated[String, ?], ?]]", ParallelTests[EitherT[Option, String, ?], Nested[Option, Validated[String, ?], ?]].parallel[Int, String])