6

我的代码中有一个场景，我需要Future根据包含某个值的成功结果来失败。我可以通过 完成这项工作flatMap，但我想知道是否有更清洁的方法来完成这项工作。首先，一个非常简化的例子：

import concurrent._

case class Result(successful:Boolean)
object FutureTest {
  def main(args: Array[String]) {
    import ExecutionContext.Implicits._

    val f = Future{Result(false)}.flatMap{ result =>
      result match{
        case Result(false) => Promise.failed(new Exception("The call failed!!")).future
        case _ => Promise.successful(result).future
      }
    }

    f onFailure{
      case x => println(x.getMessage())
    }
  }
}

因此，在我的示例中，如果返回的成功指示器的值为，我希望Future失败。正如我所提到的，我可以使用 来完成这项工作，但我想删除的代码行是：ResultfalseflatMap

case _ => Promise.successful(result).future

这种说法似乎没有必要。我想要的行为是能够定义条件，如果它评估为真，允许我返回一个不同Future的，但如果它不是真的，就保持原样（有点像PartialFunction语义。有没有办法做到这一点，我只是没有看到？我看过collect并且transform那些似乎也不合适。

编辑

在得到map@Rex Kerr 和@senia 的建议后，我创建了PimpedFuture一个隐式转换来美化代码，如下所示：

class PimpedFuture[T](f:Future[T])(implicit ex:ExecutionContext){
  def failWhen(pf:PartialFunction[T,Throwable]):Future[T] = {
    f map{
      case x if (pf.isDefinedAt(x)) => throw pf(x)
      case x => x
    }
  }
}

隐含的

  implicit def futToPimpedFut[T](fut:Future[T])(implicit ec:ExecutionContext):PimpedFuture[T] = new PimpedFuture(fut)

以及新的处理代码：

val f = Future{ Result(false) } failWhen {
  case Result(false) => new Exception("The call failed!!")
}

我认为这更清洁，同时仍然使用建议map。

4

3 回答 3

9

你可以用更少的努力做到这一点map：

val f = Future{ Result(false) } map {
  case Result(false) => throw new Exception("The call failed!!")
  case x => x
}

但是您仍然需要明确提及您正在传递身份。

请注意，您不应andThen在这种情况下使用。andThen是为了副作用，而不是为了改变结果（与Function1同名方法不同）。

于 2013-05-22T15:08:52.437 回答
0

还有一个不同的解决方案（没有@cmbaxter提到的stacktrace副作用）

val prom = Promise[Int]()
val f = future {
    1
}

f onComplete {
    case Success(i) if i < 5 => prom.failure(new RuntimeException("_ < 5"))
    case Success(x) => prom.success(x)
}

prom.future onComplete {
    case Success(s) => println(s"We cool '$s'")
    case Failure(th) => println(s"All failed, ${th.getMessage}")
}
于 2014-07-01T11:15:40.640 回答
0

filter正如@senia 在评论中提到的那样，最干净的解决方案是调用该方法。

Future { Result(false) }.filter(_.successful) // throws NoSuchElementException

如果您想要不同的异常类型，可以将调用链接到recoverWith：

Future { Result(false) }.filter(_.successful).recoverWith {
  case _: NoSuchElementException => Future.failed(new Exception("The call failed!!"))
}
于 2019-03-13T18:57:01.417 回答