Akka Actor/Scala-用于多个询问的单一onSuccess

Question

A --> B --> C

        { case msgFromA => sender ! C ? msgFromA }

A处理请求的方式是使用嵌套映射

actorRefFactory.actorOf(Props[A]) ? msgA map {
        resp =>
          // Type cast Any to Future and use another map to complete processing. 
          resp.asInstanceOf[Future[_]] map {
            case Success =>
              // Complete processing
            case Failure(exc) =>
             // Log error

这是可行的（也就是说，只有当actor C完成处理时才会进行最终处理），但不用说，它看起来很可怕。我试过使用平面地图，但不能使它工作。有什么好点子吗？）谢谢

Answer 1

更恰当的方式：

在A中：

val f: Future[MyType] = (B ? msg).mapTo[MyType]
f onComplete {
  case Success(res) => // do something
  case Failure(t) => // do something
}

在b中，使用forward:

{ case msgFromA => C forward msgFromA }

// call database
// update cache
sender() ! res   // actually sends to A