В Akka вместо использования onComplete для будущего ответа, созданного с помощью?, я пытаюсь использовать pipeTo, потому что это, предположительно, предпочтительный шаблон. Тем не менее, я, кажется, не получаю никаких Throwables или Failures, когда будущее истечет. Что я должен ожидать получить у своего актера, если тайм-аут возникает при использовании pipeTo? Как насчет того, когда будет создано другое исключение? Пример кода:
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?