過濾兩個未來[Seq]理解scala

Question

我有一些函數返回元組元素（Int，Int）的列表與未來。爲了簡單起見，我將定義兩個期貨

val f1 = Future { 
    List((8, 3), (2, 1), (4, 2), (3, 4)) 
    } 
    val f2 = Future { 
    List((2, 3), (5, 1), (7, 9)) 
    } 

我想過濾並從下面的條件中獲取這兩個未來列表中的元素。

元組包含在第二位置

相同元件在這種情況下輸出應該是

List(((2,1),(5,1)), ((8,3),(2,3))) 

我可以用正常的列表有用於理解這樣做（不期貨）象下面

val l1 = List((4, 2), (3, 4), (2, 1), (8, 3)) 
val l2 = List((2, 3), (5, 1), (7, 9)) 

val o = for { 
    a <- l1 
    b <- l2 if a._2 == b._2 
} yield (a, b) 

如何做到這一點與期貨？

Answer 1

，如果你想使用完整的理解其他的解決方案：

val o2 = for { 
    l1 <- f1 
    l2 <- f2 
} yield for { 
    a <- l1 
    b <- l2 if a._2 == b._2 
} yield (a,b) 

當然，你將有未來在這裏，所以你需要以等待結果或進一步傳遞到一些東西，會對其進行處理

Answer 2

另一種可能性是從scalaz的ListT單子變壓器（although it violates the associative law）：

import scala.concurrent.ExecutionContext.Implicits.global 
import scala.concurrent.{Await, Future} 
import scalaz.Scalaz._ 
import scalaz._ 
import scala.concurrent.duration._ 

def main(args: Array[String]): Unit = { 
    val f1 = Future { 
    List((8, 3), (2, 1), (4, 2), (3, 4)) 
    } 

    val f2 = Future { 
    List((2, 3), (5, 1), (7, 9)) 
    } 

    val first = ListT[Future, (Int, Int)](f1) 
    val second = ListT[Future, (Int, Int)](f2) 

    val res = for { 
    a <- first 
    b <- second if a._2 == b._2 
    } yield (a, b) 

    println(Await.result(res.run, 3 seconds)) 
} 

Answer 3

Scala的2.12增加了一個zipWith到Future：

f1.zipWith(f2) { 
    (l1, l2) => for { 
    a <- l1 
    b <- l2 if a._2 == b._2 
    } yield (a, b) 
} 

欲瞭解更多信息，請參見這篇博客文章：http://viktorklang.com/blog/Futures-in-Scala-2.12-part-2.html