为什么 Future.onSuccess 不会让未来失败？

Question

假设，我想在未来完成后对结果进行一些验证：

 def futureUser() {
   val foo = Future(getUserData(userId))
   foo.onSuccess { 
     case None => throw new InvalidUserId(userId)
   }
   foo // This sucks too btw: why doesn't `onSuccess` return `this` ???
 } 

这根本不像它看起来的那样：futureUser 返回一个成功的Future 或None，异常被转储到控制台并“swallen”。 看起来这实际上是故意完成的（推特期货的行为方式相同......至少，.onSuccess 是“可链接的”）。为什么？这是什么原因？

更新 好的，我需要提一下，这里使用Option 只是为了举例。请考虑一下：

def futureItems() = Future(getInterestingItems()).map { 
    case Nil => throw new NothingInterestingFound()
    case bar => bar // <-- this is the ugly piece that I could avoid if .onSuccess did not swallow failures
  }

Answer 1

这样写怎么样：

foo map { _.getOrElse(throw new Exception()) }

如 cmets 所述，onSuccess 仅在您不关心结果时才有用（只有副作用很重要）。

例如，您可以登录onSuccess。发送电子邮件也很有意义（您想在事情成功时发送它，但您不需要等待发送完成）。

Answer 2

如果您只想对成功的Future 进行验证，那么您只需要transform：

Future(getInterestingItems()).transform(validate, identity)

甚至可以很好地加糖：

implicit class FutureFailureTransform[T](private val f: Future[T]) extends AnyVal {
  def validated(isValid: T => T): Future[T] = {
    f.transform(isValid, identity)
  }
}

// Use
Future(getInterestingItems()).validated {
  case Nil => throw new NothingInterestingFound()
}

或者，如果您对NoSuchElementException 没问题，您可以使用Future.collect：

Future(getInterestingItems()) collect {
  case InterestingCase(data) => // Do stuff here
}

如果当前的未来包含一个定义了偏函数的值，那么新的未来也将持有该值。否则，生成的 future 将失败并返回 NoSuchElementException。

如果当前的未来失败了，那么由此产生的未来也失败了。

如果您需要不同的例外，您只需将collect 与transform 链接起来：

transform(identity, _ => new NothingInterestingFound())