我有一个方法:
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
复制相似问题