Wie funktioniert Future.sequence?

Question

In Scala möchte ich eine Variable vom Typ List[Future[T]] in Future[List[T]] umwandeln.

Ich weiß, ich kann Future.sequence verwenden.

Wie ist Future.sequence implementiert obwohl?

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) 
} 

Es schafft einen Samen Future für foldLeftPromise.successful verwendet, und verwendet dann einen CanBuildFrom alle Futures in eine Folge zu akkumulieren, um das Ergebnis der Akkumulierung am Ende ergibt.