Akka: Gởi nhắn tin trong tương lai để một diễn viên

Question

Tôi có đoạn mã sau bên trong một diễn viên

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

tôi không thích làm thế nào tôi có sử dụng chức năng onComplete để gửi kết quả trở lại nam diễn viên người gửi. Tôi muốn biết nếu có thể chuyển đổi nó thành một cái gì đó như thế này:

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

Tôi cảm thấy điều này chảy tốt hơn với chuỗi tương lai.

Answer 1

Bạn có thể sử dụng mẫu ống cho điều đó. Chỉ cần import akka.pattern.pipe và sau đó bạn sẽ có thể gửi thư từ tương lai đến các diễn viên với future pipeTo actor.

Answer 2

Nếu bạn muốn có một danh sách trống khi xảy ra lỗi, có thể bạn muốn có các cuộc gọi chuỗi "khôi phục" và "pipeTo".