Akka: Envoyer un futur message à un acteur

Question

je le code suivant dans un acteur

def receive = { 
    case All() => { 
     val collection: BSONCollection = db("ping") 
     val future:Future[List[Ping]] = collection.find(BSONDocument()).cursor[Ping].toList() 
     val zender = sender 
     future onComplete { 
      case Success(list) => zender ! list 
      case Failure(throwable) => zender ! List() 
     } 
    } 
} 

Je n'aime pas comment je dois utiliser la fonction onComplete pour envoyer le résultat à l'acteur de l'expéditeur. Je voudrais savoir s'il est possible de le convertir en quelque chose comme ceci:

def receive = { 
    case All() => { 
     val collection: BSONCollection = db("ping") 
     val future:Future[List[Ping]] = collection.find(BSONDocument()).cursor[Ping].toList() 
     "sender ! future" // one option 
     "future.map(list => sender ! list)" //Another option. I know it's not map, but maybe another function   
    } 
} 

Je pense que cela coule mieux avec l'enchaînement avenir.

Answer 1

Vous pouvez utiliser le modèle de tuyau pour cela. Juste import akka.pattern.pipe et alors vous serez en mesure de transmettre des messages de futures aux acteurs avec future pipeTo actor.

Answer 2

Si vous souhaitez avoir une liste vide en cas d'échec, vous voulez probablement avoir des appels chaînés de "recover" et "pipeTo".