Wie Futures Zusammensetzung

Question

zu implementieren habe ich eine Methode:

def findUserById(id: String): Future[Option[User]] 

Jetzt möchte ich eine andere Methode machen, basierend darauf:

def findUserById(ids: Seq[String]): Future[Seq[User]] 

Aber ich habe ein Problem mit Futures. Wie man die Futures-Zusammensetzung richtig implementiert?

Ich habe eine Implementierung (nicht getestet), aber ich denke, es kann einfacher gemacht werden. Auch ich bin nicht sicher über die Leistung dieser Umsetzung:

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 
    } 

Answer 1

Sie können ersetzen sequence + map mit traverse und filter + map mit flatten:

def findUsersById(ids: Seq[String]): Future[Seq[User]] = 
    Future.traverse(ids)(findUserById).map(_.flatten) 

Im Allgemeinen Future.traverse ist prägnanter als Future.sequence , und ist ein bisschen effektiver, weil es vermeidet, ein Zwischenprodukt Seq[Future[T]] zu erstellen.