scala - 映射失败的 Future 的异常

Question

最干净的方式是什么 map Exception失败的 Future在斯卡拉？

说我有:

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

val f = Future { 
  if(math.random < 0.5) 1 else throw new Exception("Oh no") 
}

如果 future 成功 1 ，我想保留它，但是如果它失败了，我想更改 Exception到另一个 Exception .

我能想到的最好的方法是转换，但这需要我为成功案例创建一个不必要的函数:

val f2 = f.transform(s => s, cause => new Exception("Something went wrong", cause))

有什么原因没有 mapFailure(PartialFunction[Throwable,Throwable]) ?

Answer 1

还有:

f recover { case cause => throw new Exception("Something went wrong", cause) }

从 Scala 2.12 开始，您可以执行以下操作:

f transform {
  case s @ Success(_) => s
  case Failure(cause) => Failure(new Exception("Something went wrong", cause))
}

或者

f transform { _.transform(Success(_), cause => Failure(new Exception("Something went wrong", cause)))}