akka - pipeTo 在超时或其他故障时发送什么消息？

Question

在 Akka 中，我没有在使用 ? 创建的 future 响应上使用 onComplete，而是尝试使用 pipeTo，因为这应该是首选模式。但是，当 future 超时时，我似乎没有收到任何 Throwables 或 Failures。如果在使用 pipeTo 时发生超时，我应该期望在我的 Actor 中收到什么？当抛出不同的异常时怎么办？示例代码:

class Simple(otherActor : ActorRef) extends Actor{
  def receive = {
     case "some_msg" => {
       val implicit timeout = Timeout(1 seconds)
       val response = otherActor ? "hello" 
       response pipeTo self
     }

     // case ??? // How do I handle timeouts?
  }
}

如果发生超时时没有自动发送消息，我应该如何使用 pipeTo 处理超时？

Answer 1

future 的失败以 akka.actor.Status.Failure 的形式发送包含异常的消息。超时的异常(exception)是 akka.pattern.AskTimeoutException .