Future的onComplete和flatMap有什么区别？

Question

我正在使用 ReactiveMongo 驱动程序编写一个 Scala 应用程序。访问数据库的方法总是返回Future[T]。以下代码段是否等效？

（与onComplete）

val results: Future[List[Tag]] = Tags.all.toList
results onComplete {
    case Success(list) => //do something with list
    case Failure(t) => //throw the error
}

（与flatMap）

Tags.all.toList.flatMap(list => //do something with list)

有什么区别？

flatMap 不会抛出Failure??而flatMap 是类似onComplete 的回调，还是等到Tags.all.toList 语句未完成？

Answer 1

如有疑问，请遵循类型。

onComplete 返回Unit，它允许你对Future 结果做一些事情，但它不会返回值

flatMap 允许您对列表进行操作并返回一个新的Future

所以flatMap 更强大，因为它允许您链接多个期货，沿途使用它们的值做一些事情，并仅在最后处理失败情况。用 Erik Meijer 的话来说：“它会引导你走上幸福的道路”。

例如你可以这样做

val finalFuture = results
 .flatMap(x => /* do something and return a future */)
 .flatMap(y => /* do something else and return a future */)
 .flatMap(z => /* do something else and return a future */)
 .map(myresult => /* do something */)

如果在此过程中出现问题，链条会提前中断，您将遇到第一个错误。

这允许更好的语法

 val finalFuture = for {
    x <- results
    y <- /* do something and return a future */
    z <- /* do something and return a future */
 } yield something(z)

如果您需要处理失败情况，您现在可以使用onComplete，或者——甚至更好——直接返回Future，因为它已经包含有关异步计算是否成功的信息。