Advertisement
Guest User

Untitled

a guest
Apr 20th, 2014
88
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. //How can I convert this
  2.  
  3.  
  4. val pActor = Akka.system.actorOf(Props[ProcessActor])
  5.  
  6.     val p = Promise[ProcessFinished]
  7.     val replyTo = Akka.system.actorOf(Props(new Actor {
  8.      def receive = {
  9.        case reply:ProcessFinished  =>
  10.           p.success(reply)
  11.           context.stop(self)
  12.      }
  13.     }))
  14.  
  15.     pActor.tell(msg = ProcessStart(), sender = replyTo)
  16.  
  17.     //transforming the actor response to Play result
  18.     p.future.map(response => {
  19.       println(response)
  20.       Ok("RESPONDIO")
  21.     })  
  22.  
  23.  
  24. //Into something like this
  25.  
  26.  createActor2(Props[ProcessActor]) {
  27.       println("dentro de createActor2")
  28.       expectResult2(ProcessFinished) {
  29.         println("dentro de expectResult2")
  30.         sendMessage2(ProcessStart()) { response =>
  31.           println("dentro de sendMessage2")
  32.     OK("RESPONDIO")
  33.         }
  34.       }
  35.     }
  36.  
  37.  
  38. //This is my attempt
  39.  
  40.   def createActor2(props:Props)(f: => Unit) = {
  41.     println("Executing createActor2")
  42.     f
  43.     println("Finished createActor2")
  44.   }
  45.  
  46.   def expectResult2(resultType:AnyRef)(f: => Unit) = {
  47.     println("Executing expectResult2")
  48.     f
  49.     println("Finished expectResult2")
  50.   }
  51.  
  52.   def sendMessage2(message:AnyRef)(f: => Unit):MessageForActor = {
  53.  
  54.     println("Executing sendMessage2")
  55.     f
  56.     println("Finished sendMessage2")
  57.     MessageForActor(message)
  58.   }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement