scala - 辅助函数中的Scala async {await(…)}无法通过类型不匹配进行编译

Question

我正在尝试使用Scala的async和await处理在foldLeft调用期间给出的 future ，因此我编写了一个辅助函数来进行等待，因为我无法在嵌套函数内使用await:

  import scala.await.Await._
  def a(f: Future[T]): T = async {
    await(f)
  }

但是，以上操作失败:

Error:(33, 38) type mismatch;
 found   : scala.concurrent.Future[T]
 required: T
      def a(f: Future[T]): T = async {
                            ^

我究竟做错了什么？

Answer 1

就像错误所说的一样，返回类型必须是Future[T]。异步块始终返回 future 。

Here是async和await的签名:

def async[T](body: T)(implicit execContext: ExecutionContext): Future[T]
def await[T](awaitable: Future[T]): T

您可以看到 async是 T => Future[T]的功能。您可能会注意到，该签名与 Future { ... }构造函数AKA Future.apply相同。它只是构筑了 future 。

魔术在 await中。它将值(value)从 future 中拉出来，因此您可以编写“正常”外观的代码，同时仍可以处理 future 。