"Futures" in bir listesini nasıl oluştururum?

Question

Promises koleksiyonum var. Ortaya çıkan Futures'u oluşturmak için etkili bir yol arıyordum. Şu ben onları birleştirmek için bulduğumuz en temiz yolu şöyle bir scalaz Monoid kullanmaktı: scalaz gerektirmediğini Bunu yapmak için temiz bir yolu

val promises = List(Promise[Unit], Promise[Unit], Promise[Unit]) 

    promises.map(_.future).reduce(_ |+| _).onSuccess { 
    case a => println(a) 
    } 

    promises.foreach(_.success(())) 

var mı? Koleksiyondaki Futures sayısı, koleksiyonda değişecektir ve çok sayıda ara koleksiyon arzu edilmeyecektir.

Answer 1

Sen Future.traverse kullanabilirsiniz:

import scala.concurrent.ExecutionContext.Implicits.global 
import scala.concurrent.{ Future, Promise } 

val promises = List(Promise[Unit], Promise[Unit], Promise[Unit]) 
Future.traverse(promises)(_.future) 

Bu size de biliyorum "ara koleksiyonları sürü" olarak nitelemek değil, ama ille ideal değildir gelmez bir Future[List[Unit]], verecektir. Future.reduce da çalışır:

Future.reduce(promises.map(_.future))((_, _) =>()) 

Bu future hiç memnun olduğunda memnun olacak bir Future[Unit] döndürür.

Answer 2

Future.sequence9, istediğiniz yöntemdir.