Advertisement
Guest User

Untitled

a guest
Feb 1st, 2014
266
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. import ActorDSL._
  2.  
  3. case class Work(...)
  4. case object AfrerTheLastMessage
  5.  
  6. actor(system, "test")(new Act {
  7.   val waiting: Receive = {
  8.     case w: Work =>
  9.       self ! AfrerTheLastMessage
  10.       become(searchingForWork(w, sender))
  11.   }
  12.   def searchingForWork(lastWorkSoFar: Work, itsSender: ActorRef): Receive = {
  13.     case AfrerTheLastMessage =>
  14.       processWork(lastWorkSoFar, itsSender)
  15.       become(waiting)
  16.     case w: Work => become(searchingForWork(w, sender))
  17.   }
  18.   become(waiting)
  19. })
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement