Scalaは、</p> Aは、対応する将来の実行の結果である <pre><code>Map[String, A] </code></pre> <p>に</p> <pre><code>Map[String, Future[A]] </code></pre> <p>から行くための最善の方法は何先物

Question

のマップを実行しますか？

これはコンパイルされません。

val results = for { 
    (key, future) <- myMap 
    result <- future 
} yield (key, result) 

私は理解のために同じで先物や反復可能オブジェクトを混在させることはできませんよう。おそらく、このような

Answer 1

あなたはSeq[Future[(String,A)]]に変換する場合は、その後、単一Future[Map[...]]それを取り戻すためにFuture.foldを使用することができます。

def transform[A](m: Map[String, Future[A]]): Future[Map[String, A]] = { 
    val seq: Seq[Future[(String, A)]] = m.toSeq.map { case (key, f) => 
    f.map(i => key -> i) 
    } 

    Future.fold(seq)(Map.empty[String, A])(_ + _) 
} 

はその後、通常のように、単一の未来を買い戻します。

Answer 2

何か：

map.mapValues { Await.result(_, 5 seconds) } 

Answer 3

ディマはすでにAwaitを使用して答えを与えました。しかし、未来が失敗したときに例外が発生します。

さらに型をTryとしてラップしてから、.collectを実行して、正常なFuturesのみをフィルタリングすることができます（公式APIをチェックしてください）。

import scala.util.{ Try, Success } 

val results = myMap 
    .map { 
     case (key, value) => key => Try(Await.result(value, 5.seconds)) 
    } 
    .collect { 
     case (key, Success(value)) => key -> value 
    } 

上記の呼び出しでは、失敗した先物は自動的に破棄され、成功したもののみが回収されます。