如何从几个 Future[\/[Throwable, T]] 中获取 Future[\/[Throwable, T]]

Question

假设我有几种方法可以返回\/[Throwable, String]。右边的值Int是我想要的，左边的值会累积错误。

import scalaz._
import Scalaz._
type ErrorOr[T] = \/[Throwable, T]

def init(a: Int): ErrorOr[Int] = a.right
def add(a: Int, b: Int): ErrorOr[Int] = (a + b).right
def multiply(a: Int, b: Int): ErrorOr[Int] = (a * b).right

init(3).flatMap(add(_, 4)).flatMap(multiply(_, 3)) // 21

看起来不错，因为 scalaz any 的平面图是右偏的，所以它会根据正确的值进行操作。

但是，如果要更改 API 调用的方法，则返回类型将为 Future[ErrorOr[T]]。有什么方法可以用来返回Future[ErrorOr[T]]？另外，我可能想使用future.flatMap 作为回调，而不是在这里使用await 来阻止

def init(a: Int): Future[ErrorOr[Int]] = Future(a.right)
def add(a: Int, b: Int): Future[ErrorOr[Int]] = Future((a + b).right)
def multiply(a: Int, b: Int): Future[ErrorOr[Int]] = Future((a * b).right)

Answer 1

您可以像现在一样将init 的结果包装在EitherT monad 转换器中，使用flatMapF 而不是flatMap 直接使用add 和multiply，然后调用run回复Future[ErrorOr[Int]]：

EitherT(init(3)).flatMapF(add(_, 4)).flatMapF(multiply(_, 3)).run

Answer 2

你可以考虑使用scalaz.concurrent.Task:

def init(a: Int): Task[Int] = Task.now(a)
def add(a: Int, b: Int): Task[Int] = Task.now(a + b)
def multiply(a: Int, b: Int): Task[Int] = Task.now(a * b)

所以：

scala> val res = init(3).flatMap(add(_, 4)).flatMap(multiply(_, 3))
res: scalaz.concurrent.Task[Int] = scalaz.concurrent.Task@3fdb3076

可以轻松转换为：

scala> res.get
res1: scalaz.concurrent.Future[scalaz.\/[Throwable,Int]] = ...

scala> res.get.run
res5: scalaz.\/[Throwable,Int] = \/-(21)

如果你需要失败：

scala> def add(a: Int, b: Int): Task[Int] = Task.fail(new RuntimeException("fail"))
add: (a: Int, b: Int)scalaz.concurrent.Task[Int]

scala> init(3).flatMap(add(_, 4)).flatMap(multiply(_, 3)).get.run
res4: scalaz.\/[Throwable,Int] = -\/(java.lang.RuntimeException: fail)

请注意，这里的Future 是scalaz.concurrent.Future

更新

如果你需要将Either 传递给任务 - 你可以使用这个：

import Task._

implicit class FutureToTask[T](f: Future[\/[Throwable, T]]){
   def task = async(f.runAsync)
}