Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def receive = {
- case sp: SavePhoto =>
- saveBuffer ! sp.withReplyTo(context.actorSelection(sender().path) :: sp.replyTo)
- case rp: RemovePhotos if !rp.filter.isEmpty =>
- RemovePhotosStream(rp)
- .runWith(Sink.ignore)
- .failed
- .foreach(e => log.error(e, "failed to remove photos"))
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement