Scala: List[Future] to Future[List] disregarding failed futures

by

The trick is to first make sure that none of the futures has failed. .recover is your friend here, you can combine it with map to convert all the Future[T] results to Future[Try[T]]] instances, all of which are certain to be successful futures.

note: You can use Option or Either as well here, but Try is the cleanest way if you specifically want to trap exceptions

def futureToFutureTry[T](f: Future[T]): Future[Try[T]] =
  f.map(Success(_)).recover { case x => Failure(x)}

val listOfFutures = ...
val listOfFutureTrys = listOfFutures.map(futureToFutureTry(_))

Then use Future.sequence as before, to give you a Future[List[Try[T]]]

val futureListOfTrys = Future.sequence(listOfFutureTrys)

Then filter:

val futureListOfSuccesses = futureListOfTrys.map(_.filter(_.isSuccess))

You can even pull out the specific failures, if you need them:

val futureListOfFailures = futureListOfTrys.map(_.filter(_.isFailure))

More Related Contents:

  1. Scala’s “for comprehension” with futures
  2. Accessing value returned by scala futures
  3. How do I make a function involving futures tail recursive?
  4. How to wait for several Futures?
  5. Scala recover or recoverWith
  6. Futures do not run before program termination
  7. Futures / Success race
  8. What is the apply function in Scala?
  9. How do I apply the enrich-my-library pattern to Scala collections?
  10. How to cancel Future in Scala?
  11. How to model type-safe enum types?
  12. Scala constructor overload?
  13. Reading DataFrame from partitioned parquet file
  14. What type to use to store an in-memory mutable data table in Scala?
  15. Build.scala, % and %% symbols meaning
  16. Result type of an implicit conversion must be more specific than AnyRef
  17. Usefulness (as in practical applications) of Currying v.s. Partial Application in Scala
  18. Perform a typed join in Scala with Spark Datasets
  19. Left Anti join in Spark?
  20. DataFrame-ified zipWithIndex
  21. How to access parameter list of case class in a dotty macro
  22. Can’t access Parent’s Members while dealing with Macro Annotations
  23. Why is join not possible after show operator?
  24. What does a single apostrophe mean in Scala? [duplicate]
  25. Treating an SQL ResultSet like a Scala Stream
  26. Queries with streaming sources must be executed with writeStream.start();
  27. Singletons as Synthetic classes in Scala?
  28. Understanding the Aux pattern in Scala Type System
  29. Akka-Stream implementation slower than single threaded implementation
  30. Multiple parameter closure argument type not inferred

Leave a Comment