Scala, выполнить карту фьючерсов

Question

Что это лучший способ, чтобы перейти от

Map[String, Future[A]] 

в

Map[String, A] 

где А является результатом выполнения Соответствующее будущегокиевстар?

Это не будет компилироваться:

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

как я не могу смешивать фьючерсы и итерируемых в то же самое для понимания.

Answer 1

Если преобразовать его в Seq[Future[(String,A)]], вы можете использовать Future.fold, чтобы получить его обратно один Future[Map[...]]:

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, чтобы фильтровать только для успешных фьючерсов (ознакомьтесь с официальным 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 
    } 

С вызовом выше вы автоматически отказываетесь от фьючерсов и собираете только успешные.