def trySequence[A, M[X] <: TraversableOnce[X]]()

in src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala [58:64]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  def trySequence[A, M[X] <: TraversableOnce[X]](in: M[Future[A]])(implicit
      cbf: CanBuildFrom[M[Future[A]], Try[A], M[Try[A]]],
      executor: ExecutionContext): Future[M[Try[A]]] =
    in.foldLeft(Future.successful(cbf(in))) { (fr, a) =>
      val fb = lift(a)
      for (r <- fr; b <- fb) yield r += b
    }.map(_.result())