scala - 如何使用 transformWith() 忽略失败的 future ？

Question

我需要将一系列转换处理成一个转换，以便如果我有一些失败的 Future 它应该被忽略(我试图在没有 recover 或 recoverWith 的情况下执行它，但是出错了，遇到任何代码都会失败失败)

type Transformation[T] = T => Future[T]
//in - Seq(trans1, trans2, trans3)

in.reduce[Transformation[T]](
  (acc, el) =>
    acc.andThen[Future[T]](
      ft =>
        ft.flatMap(el)
          .transformWith[T](
            t =>
              t match {
                case Failure(exception) => ft //this line is the most suspicious for me
                case Success(value)     => Future.successful(value)
              }
          )
    )
)

Answer 1

transformWith 似乎无法为您提供从上一步恢复原始输入值的可能性，因为它必须使用 Try。如果 Try 失败了怎么办？到那时，它没有原始输入可以回退，它只有一个 Throwable，而不是一个 T。所以，transformWith 似乎不够。

如果管道只有几个转换长，您可以尝试使用 foldLeft 和 fallbackTo:

import scala.concurrent._
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

type Transformation[T] = T => Future[T]
def chainTrafos[T](
  trafos: List[Transformation[T]],
  value: T
): Future[T] = {
  trafos.foldLeft(Future { value })(
    (f, t) => f.flatMap(x => t(x).fallbackTo(Future { x }))
  )
}


val ta: Transformation[Int] = x => Future { x * x }
val tb: Transformation[Int] = x => Future.failed(new Error("oops"))
val tc: Transformation[Int] = x => Future { x - 58 }

println(Await.result(chainTrafos(List(ta, tb, tc), 10), 10.seconds))

打印

42