await - Combinar secuencialmente un número arbitrario de futuros en Scala

await future scala

Question

Soy nuevo en scala e intento combinar varios futuros en scala 2.10RC3. Los Futures deben ejecutarse en orden secuencial. En el documento Scala SIP14, el método y andThen se define para ejecutar futuros en orden secuencial. Utilicé este método para combinar varios Futures (ver ejemplo a continuación). Mi expectativa era que imprima 6 pero en realidad el resultado es 0 . ¿Qué estoy haciendo mal aquí? Tengo dos preguntas:

Primero, porque es el resultado 0 . En segundo lugar, ¿cómo puedo combinar varios Futures , para que la ejecución del segundo Future no comience antes de que se haya terminado el primer Future ?

val intList = List(1, 2, 3)
val sumOfIntFuture = intList.foldLeft(Future { 0 }) {
case (future, i) => future andThen {
case Success(result) => result + i
case Failure(e) => println(e)
}
}
sumOfIntFuture onSuccess { case x => println(x) }

Answer 1

andThen es para los efectos secundarios. Le permite especificar algunas acciones para hacer después de que se complete el futuro y antes de que se use para otra cosa.

Usar mapa:

scala> List(1, 2, 3).foldLeft(Future { 0 }) {
| case (future, i) => future map { _ + i }
| } onSuccess { case x => println(x) }
6

Answer 2

Me gusta este enfoque genérico:

trait FutureImplicits {
class SeriallyPimp[T, V](futures: Seq[T]) {
def serially(f: T => Future[V])(implicit ec: ExecutionContext): Future[Seq[V]] = {
val buf = ListBuffer.empty[V]
buf.sizeHint(futures.size)
futures.foldLeft(Future.successful(buf)) { (previousFuture, next) =>
for {
previousResults <- previousFuture
nextResult <- f(next)
} yield previousResults += nextResult
}
}
}
implicit def toSeriallyPimp[T, V](xs: Seq[T]): SeriallyPimp[T, V] =
new SeriallyPimp(xs)
}

Luego mezcla el rasgo anterior y úsalo así:

val elems: Seq[Elem] = ???
val save: Elem => Future[Result] = ???
val f: Future[Seq[Result]] = elems serially save

Este código podría mejorarse para preservar el tipo de colección de entrada. Ver este artículo por ejemplo.