基于第一个未来结果的Scala未来回报

Question

我有一个Scala future，它调用一个api并返回future，如果结果不正确，那么另一个api调用将与第一个future的结果一起提交并作为future返回。

这是我目前为止所拥有的。

val fut1 = Future(queryFirst)
val fut2 = fut1 map {
  case y if y.isInstanceOf[NoResult] => Future(queryAgainWithFut1Result)
  case x => x
}

但是如果我访问fut2结果，它会给出这样的结果:

scala.concurrent.Await.result(fut2, 5 seconds)
warning: there was one feature warning; re-run with -feature for details
fut2: Any = scala.concurrent.impl.Promise$DefaultPromise@61ab71c2

有没有一种方法，我可以选择返回fot2，如果fot1的结果是不准确的？

编辑：第二个未来必须使用第一个未来来继续API调用。这就是我到目前为止所拥有的。

val fut1 = Future("queryFirst")
val fut2 = fut1 flatMap {
  case y if y.isInstanceOf[Int] => Future("queryAgainWithResult(y)")
  case x => Future(x)
}

Answer 1

您可以< code >筛选第一个< code>Future，使其在包含的结果与您想要的结果不匹配时失败，然后使用< code>recoverWith将值恢复到另一个< code>Future。

Future(queryFirst)
    .filter(result => /* logic that returns true if result is correct */)
    .recoverWith { case NonFatal(e) => Future(querySecond) }

如果< code>queryFirst成功并通过了< code >过滤器，那么它的结果将被返回(包装在< code>Future中)。

如果< code>queryFirst成功，但根据< code>filter没有正确的值或只是失败，则将返回< code>Future(querySecond)的结果，成功或失败。

编辑：根据OP中的新信息，如果您需要错误的第一个Future的结果，那么您实际上别无选择，只能使用平面图。

Future(queryFirst).flatMap {
    case result if(/* failed condition */) => Future(querySecond(result))
    case result => Future.successful(result)
}