Akka: Wyślij wiadomość do przyszłego aktora

Question

Mam następujący kod wewnątrz aktora

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() 
     } 
    } 
} 

Nie lubię jak muszę użyć funkcji onComplete wysłać wynik z powrotem do nadawcy aktora. Chciałbym wiedzieć, czy można go przekonwertować na coś takiego:

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   
    } 
} 

Uważam, że to płynie lepiej z przyszłym łańcuchem.

Answer 1

Można użyć wzoru rury dla tego. Po prostu import akka.pattern.pipe, a następnie będziesz mógł przesyłać wiadomości z przyszłości do aktorów z numerem future pipeTo actor.

Answer 2

Jeśli chcesz mieć pustą listę, gdy wystąpi awaria, prawdopodobnie chcesz mieć połączone połączenia "odzyskać" i "potoczyć".