Scala 2.12 Future 和 Either 的组合（有偏见的版本）

Question

我有两个方法，并且都返回 Future[Either[String, T]] 并希望将它们链接在一起以完成工作。我现在使用的是 Scala 2.12 无论是正确的偏见。

例如，

如果函数不返回 Future 和 Either 组合，我可以简单地执行以下操作。

def convert(a, b) = ???
def callA(): Future[A] = ???
def callB(a: A): Future[B] = ???

def chain: Future[C] = for {
  a <- callA
  b <- callB(a)
} yield convert(a, b)

但现在我想使用以下语法捕获错误，并传播到最终结果。实现这一目标的最佳方法是什么？也应该使用 callB 或 callB1 吗？

def convert(a, b): Future[Either[String, C]] = ???
def callA(): Future[Either[String, A]] = ???
def callB(a: A): Future[Either[String, B]] = ??? or 
def callB1(eithera: Either[String, A]): Future[Either[String, B]] = ???

我知道使用猫转换单子可以简化这一点。欢迎给我使用标准库和猫的解决方案。

Answer 1

正如 cmets 所提到的，这是 cat 和 scalaz 可以处理的事情。但我也可以理解不为一小段逻辑引入另一个依赖项或复杂性的愿望。如果你想自己实现它，你可以这样做：

implicit class FutureEither[A](val wrapped: Future[Either[String, A]])(implicit ec: ExecutionContext) {
  def map[B](f: A => B): FutureEither[B] = wrapped.map(_.map(f))

  def flatMap[B](f: A => FutureEither[B]): FutureEither[B] = wrapped.flatMap {
    case Left(s) => Future(Left(s))
    case Right(a) => f(a).wrapped
  }
}

使用适当的类型实现 map 和 flatMap 可以实现完全相同的理解风格：

def convert(a: A, b: B): C = ???
def callA(): FutureEither[A] = ???
def callB(a: A): FutureEither[B] = ???

def chain: FutureEither[C] = for {
  a <- callA()
  b <- callB(a)
} yield convert(a, b)