Scala - 期货和二选一

Question

这个帖子让我知道了如何构建我的代码：Scala-way to handle conditions in for-comprehensions?

有问题的部分：

// First create the JSON
val resultFuture: Future[Either[Failure, JsResult]] = for {
  userRes <- userDao.findUser(userId)
  user    <- userRes.withFailure(UserNotFound).right
  authRes <- userDao.authenticate(user)
  auth    <- authRes.withFailure(NotAuthenticated).right
  goodRes <- goodDao.findGood(goodId)
  good    <- goodRes.withFailure(GoodNotFound).right
  checkedGood <- checkGood(user, good).right
} yield renderJson(Map("success" -> true)))

这是我不明白的行：

user    <- userRes.withFailure(UserNotFound).right
authRes <- userDao.authenticate(user)

userRes.withFailure(UserNotFound).right 映射到 userDao.authenticate(user)。这将创建一个新的 Either，其右侧有一个 Future，对吗？

怎么可能

val resultFuture: Future[Either[Failure, JsResult]]

属于它的类型。我认为应该有另一个未来，而不是 JsResult。 谁能给我解释一下？

编辑：既然 cmbaxter 和 Arne Claassen 确认了这一点，那么新的问题是：我应该如何编写这段代码，这样它看起来才不会难看，而且干净且结构化？

Answer 1

我相信当Future 已经完全能够传达失败时，您收到的答案不必要地将Either 混入其中。您缺少的主要内容是一种从 Option 获取选项值而不显式抛出异常的方法。

我建议您将 Failures 对象更改为以下内容：

object Failures {

  sealed trait Failure extends Exception

  // Four types of possible failures here
  case object UserNotFound extends Failure

  case object NotAuthenticated extends Failure

  case object GoodNotFound extends Failure

  case object NoOwnership extends Failure

  // Put other errors here...

  // Converts options into Futures
  implicit class opt2future[A](opt: Option[A]) {
    def withFailure(f: Failure) = opt match {
      case None => Future.failed(f)
      case Some(x) => Future.successful(x)
    }
  }
}

现在您可以将 Future[Option[A]] 映射到 Future[A] 并指定失败条件，从而得到如下的 for 理解：

def checkGood(user: User, good: Good) =
  if (checkOwnership(user, good))
    Future.successful(good)
  else
    Future.failed(NoOwnership)

val resultFuture: Future[JsResult] = for {
  userOpt <- userDao.findUser(userId)
  user <- userOpt.withFailure(UserNotFound)
  authOpt <- userDao.authenticate(user)
  auth <- authOpt.withFailure(NotAuthenticated)
  goodOpt <- goodRes.withFailure(GoodNotFound)
  checkedGood <- checkGood(user, good)
} yield renderJson(Map("success" -> true))))

现在您有了Future[JsResult]，您可以将失败的场景映射到您想要的输出，而成功的场景就是 JsResult。希望您在一个异步框架中使用它，该框架期望您为它提供一个未来，并且有它自己的失败未来到错误响应映射（例如 Play！）。