scala - `Future[Option[Future[Option[X]]]]` 变为 `Future[Option[X]]`

Question

如何将Future[Option[Future[Option[X]]]]转换为Future[Option[X]]？

如果它是 TraversableOnce 而不是 Option 我会使用 Future companion object ;但是选项呢？

示例:

def processAndReturnFuture(x:String):Future[String] = future(x)
def processAgainAndReturnOption(x:String):Option[String] = Some(x)

val futOpt:Future[Option[String]] = future(Some("x"))
val futOptFutOpt:Future[Option[Future[Option[String]]]] =
  futOpt.map( opt =>
    opt.map( x =>
      processAndReturnFuture(x).map( processedX =>
        processAgainAndReturnOption(processedX)
      )
    )
  )

Answer 1

更新答案

这可能会起作用。我所做的是将前两个 map 调用替换为最外层 Future 上的 flatMap 和最外层 Option 上的模式匹配.

val futOptFutOpt: Future[Option[String]] =
  futOpt.flatMap {
    case None => Future.successful(None)
    case Some(x) =>
      processAndReturnFuture(x).map {
        processedX => processAgainAndReturnOption(processedX)
      }
  }

初始答案

我假设您代码中的某个位置有一个 map 调用，它将 Future[Option[A]] 转换为 Future[Option[Future[Option [X]]]]。将 map 替换为 flatMap 并删除结果中最上面的 Option 图层。您最终会得到 Future[Option[X]]。这就是我的意思:

scala> import scala.concurrent._
import scala.concurrent._

scala> import ExecutionContext.Implicits.global
import ExecutionContext.Implicits.global

scala> val f1: Future[Option[Future[Option[String]]]] =
     | Future.successful(Some(1)).map(v => Some(Future.successful(Some(v.toString))))
f1: scala.concurrent.Future[Option[scala.concurrent.Future[Option[String]]]] = scala.concurrent.impl.Promise$DefaultPromise@6f900132

scala> val f2: Future[Option[String]] =
     | Future.successful(Some(1)).flatMap(v => Future.successful(Some(v.toString)))
f2: scala.concurrent.Future[Option[String]] = scala.concurrent.impl.Promise$DefaultPromise@2fac9a62

对于您的实际上下文，我可能并不完全正确，但您可能可以通过用一些 flatMap 替换一些 map 来解决这个问题.