在获得一些帮助并进行研究之后,我发现了以下实现,这对我来说似乎是迄今为止最优雅的:
1. 不使用额外的依赖:
def combineTasks[A, B, C, D](task1: Task[Option[A]],
task2: Task[Option[B]],
task3: Task[Option[C]])
(f: (A, B, C) => D)
: Task[Option[D]] = {
for {
t1 <- task1
t2 <- task2
t3 <- task3
} yield {
(t1, t2, t3) match {
case (Some(t1), Some(t2), Some(t3)) => Some(f(t1, t2, t3))
case _ => None
}
}
}
2. 使用scalaz-zio-interop-cats
和cats
:
def combineTasks[A, B, C, D](task1: Task[Option[A]],
task2: Task[Option[B]],
task3: Task[Option[C]])
(f: (A, B, C) => D)
: Task[Option[D]] = {
import cats.implicits.catsStdInstancesForOption
import cats.Apply
import scalaz.zio.interop.catz._
Apply[Task].compose[Option].map3(task1, task2, task3)(f)
}
参见mapN over composition 申请相关讨论。
3. 使用scalaz-zio-interop-scalaz7x
和scalaz7x
:
def combineTasks[A, B, C, D](task1: Task[Option[A]],
task2: Task[Option[B]],
task3: Task[Option[C]])
(f: (A, B, C) => D): Task[Option[D]] = {
import scalaz.Apply
import scalaz.std.option._
import scalaz.zio.interop.scalaz72._
Apply[Task].compose[Option].apply3(task1, task2, task3)(f)
}