理解Scala上的类型不匹配:scala.concurrent.Future

Question

我对Scala很陌生，请耐心等待。我有一堆包裹在一个大数组中的期货。期货已经完成了他们的辛勤工作，查看了一些TB的数据，在我的应用程序结束时，我想总结所有的结果，这样我就可以很好地展示它们。

我拥有的期货集合属于以下类型：

Array[Future[List(String, String, String)]]

到目前为止，我读到的所有关于理解的东西都表明

val test: Seq[Seq[List[String]]] = Seq(Seq(List("Hello", "World"), List("What's", "Up")))

val results = for {
  test1 <- test
  test2 <- test1
  test3 <- test2
} yield test3

导致

results: Seq[String] = List(Hello, World, What's, Up)

按照同样的逻辑，我的意图是这样做，因为我最近发现选项，尝试，失败和成功可以被视为集合：

val futures = { ... } // Logic that collects my Futures

// futures is now Array[Future[List(String, String, String)]]

val results = for {
  // futureSeq as Seq[List(String, String, String]
  futureSeq <- Future.sequence(futures.toSeq)
  // resultSet as List(String, String, String)
  resultSet <- futureSeq
} yield resultset

但这不一定行得通。我似乎收到了以下编译错误：

错误：（78,15）类型不匹配；
找到：Seq[List（String， String， String）]
必需：scala.concurrent.Future[？]

结果集

带有必需的部分：scala.concurrent.Future[？]完全抛弃了我。我完全不明白为什么那里需要一个未来。

我已通过 REPL、调试和使用 IntelliJ 的类型检查检查检查了所有对象的类型。他们似乎证实了我不仅仅对自己的类型感到困惑。

在任何人提到之前，是的，我知道理解是一堆地图，平面地图和filters的句法糖。

Answer 1

关于＜code＞for＜/code＞的＜code＞如何理解调用＜code＞flatMap＜/code＞和＜code＞map＜/code＞的细节在这里很重要。该代码：

for {
  futureSeq <- Future.sequence(futures.toSeq)
  resultSet <- futureSeq
} yield resultset

变得或多或少像这样：

Future.sequence(futures.toSeq).flatMap(futureSeq => futureSeq)

Future 上的 flatMap 需要一个返回 Future 的函数，但您给它一个函数返回一个 Seq[List[（String， String， String）]]。

通常，您不能在理解中混合使用类型（序列理解中的选项是隐式转换支持的一种例外）。如果您有

你可能想要这样的东西：

val results: Future[Seq[(String, String, String)]] =
  Future.sequence(futures.toSeq).map(_.flatten)

然后你可以用这样的东西：

import scala.concurrent.Await
import scala.concurrent.duration._

Await.result(results.map(_.map(doSomethingWithResult)), 2.seconds)

同步呈现结果(阻塞直到完成)。