Future.sequenceはどのように機能しますか？

Question

Scalaでは、タイプList[Future[T]]の変数をFuture[List[T]]に変換したいと考えています。

Future.sequenceを使用することができます。

Future.sequenceはどのように実装されていますか？

Answer 1

Like this：

/** Simple version of `Futures.traverse`. 
* Transforms a `TraversableOnce[Future[A]]` into a `Future[TraversableOnce[A]]`. 
* Useful for reducing many `Future`s into a single `Future`. 
*/ 
def sequence[A, M[X] <: TraversableOnce[X]] 
      (in: M[Future[A]]) 
      (implicit cbf: CanBuildFrom[M[Future[A]], A, M[A]], 
      executor: ExecutionContext): Future[M[A]] = { 
    in.foldLeft(successful(cbf(in))) { 
    (fr, fa) => for (r <- fr; a <- fa) yield (r += a) 
    }.map(_.result())(InternalCallbackExecutor) 
} 

それはPromise.successfulを用いfoldLeftためのシードFutureを作成し、終了時に累積の結果をもたらす、配列内のすべての先物を蓄積するCanBuildFromを使用します。