对于具有 if 筛选器的表达式会导致错误

Question

如何重构我的代码，以便我的 for 表达式中没有 if 语句？

我得到一个执行异常:

[NoSuchElementException: Future.filter predicate is not satisfied]

我正在下面定义一个if选项，这导致了问题：

val maybeUserFut: Future[Option[User]] = 
    for {
          usernameOpt <- lookupUsername("...")
          if usernameOpt.isDefined
            userOpt <- getUser(usernameOpt.get)
        } userOpt

我应该开始使用什么模式来避免此错误？

Answer 1

for {
  usernameOpt <- lookupUsername("...")
  if usernameOpt.isDefined
    userOpt <- getUser(usernameOpt.get)
} yield userOpt

被转化成

lookupUsername("...")
  .withFilter({ usernameOpt => usernameOpt.isDefined })
  .flatMap({ usernameOpt =>
    getUser(usernameOpt.get).map({ userOpt =>
      userOpt
    })
})

< code>Future.withFilter定义为(source):

def filter(p: T => Boolean)(implicit executor: ExecutionContext): Future[T] =
  map {
    r => if (p(r)) r else throw new NoSuchElementException("Future.filter predicate is not satisfied")
  }

因此，没有一个简单的转换会起作用。

我可能会这样写：

lookupUsername("...").flatMap({ usernameOpt =>
  usernameOpt match {
    case None           => Future.successful(None)
    case Some(username) => getUser(username)
  }
})

如果您想使用< code>for comprehension语法，您将需要一个像Scalaz OptionT这样的monad转换器，它将显式提升抽象为< code>Future(例如< code>case None =

import scalaz._
import Scalaz._
import scalaz.OptionT._

val maybeUserFut: Future[Option[User]] = 
  (for {
    username <- optionT(lookupUsername("..."))
    user <- optionT(getUser(username))
  } yield user).run