Wie vereinfacht man die zukünftige Ergebnisbehandlung in Akka/Futures?

Question

Ich möchte meinen Codevereinfachen, um es so einfach wie möglich zu machen.

Hier ist der Code

case object Message 

class SimpleActor extends Actor { 
    def receive = { 
    case Message => sender ! Future { "Hello" } 
    } 
} 

object SimpleActor extends App { 

    val test = ActorSystem("Test") 
    val sa = test.actorOf(Props[SimpleActor]) 

    implicit val timeout = Timeout(2.seconds) 

    val fRes = for { 
    f <- (sa ? Message).asInstanceOf[Future[Future[String]]] 
    r <- f 
    } yield r 

    println { 
    Await.result(fRes, 5.seconds) 
    } 

} 

Ist es möglich, diesen Teil

.asInstanceOf[Future[Future[String]]] 

loswerden?

Answer 1

Sehen Sie sich die pipeTo Funktion an, bei der es darum geht, einen Future zwischen den Aktoren zu übergeben. Siehe here auf fragen Muster.

myFuture pipeTo sender 

Der Rückgabetyp Ihres wird Future[String] in Ihrem Fall fragen, die als Sie Ihren Kommentar unten müssen die mapTo[String] fragt tatsächlich das Ergebnis Typ erhalten eine String zu sein. So kann Ihr für-comp ditched werden konnte und direkt aufgerufen:

val fRes = (sa ? Message).mapTo[String]