Акка актеров/Scala - одного OnSuccess для нескольких спрашивает

Question

У меня есть цепь AKKA актеров, как

A --> B --> C 

Актер А «просит» актер B, который в свою очередь «просит» актер С. актеру нужно ждать пока актер C не завершил обработку. B представляет собой тонкий слой, и ничего не делает больше, чем передача (с просьбой) сообщение на C и возвращает будущее обратно к A. В основном B вобще

 { case msgFromA => sender ! C ? msgFromA } 

Поэтому то, что получает это будущее [Любой].

Способ А обработки запроса использует вложенные карты

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 

Это работает (то есть окончательная обработка происходит только тогда, когда актер C закончит обработку), но само собой разумеется, что выглядит ужасно. Я пробовал использовать flatmaps, но не мог заставить его работать. Любые идеи, чтобы сделать его хорошо выглядеть :) Спасибо

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 } 

В C:

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