按未来结果收集Scala过滤器

Question

我有一个名为Source的类，它有lazy val isValid来做一些需要时间的网络检查。我让它返回Future[Boolean],这样它就不会阻塞主线程:

lazy val isValid: Future[Boolean] = doSomeChecks()

现在，我想检查几个来源并丢弃无效的来源。
下面是一些伪代码：

val sources = Seq(Source1, Source2,...)
val validOnes: Seq[Source] = sources.filter(_.isValid)

我在想一些方法，可以将从isValid返回的Future[Boolean]转换为其他将来，在验证检查完成后，可以使用整个源对象进行解析。

最好的方法是什么？

Answer 1

无需从返回源代码本身是有效的。只需将源代码本身附加到isValid请求的每个结果。有效性检查的结果出现后，过滤那些有效的源，并丢弃有效性布尔值：

val sources: Seq[Source] = ...

val validSources: Future[Seq[Source]] = (for {
  checkedSources <- Future.sequence(
    sources.map(s => s.isValid.map(b => (s, b)))
  )
} yield checkedSources.filter(_._2).map(_._1))

这里，< code>s.isValid返回一个< code>Future[Boolean]。这个未来是用< code>b =映射的

我不确定这是否是做到这一点的“最佳”方式，因为我不清楚有效性检查保持足够“新鲜”的时间有多长:很可能在所有结果都收集到< code>checkedSources序列中时，< code>isValid检查的结果中有一半已经过期。

编辑(1):更短:

val validSources: Future[Seq[Source]] = 
  Future.sequence(sources.map(_.isValid)).map {
    bs => (sources zip bs).filter(_._2).map(_._1)
  }

这个应该也可以。

(代码未经检查用编译器，粗略的草图了我的头顶；如果您想要一个可编译的解决方案，请提供最小的可编译示例)