我有一个方法:
def findUserById(id: String): Future[Option[User]]
现在我想做另一种方法,基于它:
def findUserById(ids: Seq[String]): Future[Seq[User]]
但我在使用期货时遇到了一些问题。如何正确实施期货组合?
我有一个实现(未测试),但我认为它可以变得更容易。另外,我也不确定该实现的性能:
override def findUsersById(ids: Seq[String]): Future[Seq[User]] = {
val futures = ids.map(id => findUserById(id))
val filtered = Future.sequence(futures).map(_.filterNot(_.isEmpty)).map(_.map(_.get))
filtered
}
发布于 2017-06-27 17:26:46
您可以将sequence
+map
替换为traverse
,将filter
+map
替换为flatten
def findUsersById(ids: Seq[String]): Future[Seq[User]] =
Future.traverse(ids)(findUserById).map(_.flatten)
一般来说,Future.traverse
比Future.sequence
更简洁,也更有效,因为它避免了创建中间Seq[Future[T]]
。
https://stackoverflow.com/questions/44776557
复制相似问题