等待 Future[List[Object]] 在 Scala 中异步完成

Question

我有一个Future[List[Object]] 喜欢

val futuresList: Future[List[Object]] = foo()

我还有另一种方法，它采用 futuresList 并进行一些计算。

我希望这个 future 在我可以将它传递给另一个返回 Future 的方法之前完成执行。

val futuresList: Future[List[Object]] = foo()
val anotherFuture: Future[Seq[Object]] = bar(futuresList, x, y)

现在我想异步等待futureList完成，之后我想将它传递给bar()

到目前为止，我已经尝试过了

futuresList.onComplete {
  case Success(data) => {  
    //call bar here, but how do I get access 'anotherFuture' ?
  }
}

希望获得有关如何通过确保 futuresList 完整来访问来自 bar() 的响应的一些指导。谢谢

Answer 1

val anotherFuture = futuresList.flatMap(data => bar(Future.successful(data), x, y))

或者如果您更喜欢 for-comprehension 语法，它是等效的：

val anotherFuture = for {
  data <- futuresList
} yield {
  bar(Future.successful(data), x, y)
}