comment écrire un avenir qui attend un événement

Question

J'ai une socket client/serveur qui fait des choses rpc. Je connais un peu le finagle et je trouve l'isolement avec un futur très élégant. Donc, ma question serait comment écrire un avenir dans Scala qui attendent un événement (la réponse du serveur de ma demande client). La mise en œuvre utilisera probablement une requête identifiée mais ce qui me manque, c'est la manière de demander au futur d'attendre l'événement sans attendre.

Answer 1

A cet effet, vous devez jeter un oeil à Akka Actors

est ici par exemple d'un acteur

class MyActor extends Actor { 
    val log = Logging(context.system, this) 
    def receive = { 
     case "test" ⇒ log.info("received test") 
     case _  ⇒ log.info("received unknown message") 
    } 
} 

Answer 2

Créer une Promise au lieu de Future et ajouter un écouteur à votre événement qui répond à la promesse. Retournez l'avenir de la promesse à votre client (dans Twitter Util future bibliothèque c'est la promesse elle-même, dans Scala 2.10 c'est p.future).