Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //How can I convert this
- val pActor = Akka.system.actorOf(Props[ProcessActor])
- val p = Promise[ProcessFinished]
- val replyTo = Akka.system.actorOf(Props(new Actor {
- def receive = {
- case reply:ProcessFinished =>
- p.success(reply)
- context.stop(self)
- }
- }))
- pActor.tell(msg = ProcessStart(), sender = replyTo)
- //transforming the actor response to Play result
- p.future.map(response => {
- println(response)
- Ok("RESPONDIO")
- })
- //Into something like this
- createActor2(Props[ProcessActor]) {
- println("dentro de createActor2")
- expectResult2(ProcessFinished) {
- println("dentro de expectResult2")
- sendMessage2(ProcessStart()) { response =>
- println("dentro de sendMessage2")
- OK("RESPONDIO")
- }
- }
- }
- //This is my attempt
- def createActor2(props:Props)(f: => Unit) = {
- println("Executing createActor2")
- f
- println("Finished createActor2")
- }
- def expectResult2(resultType:AnyRef)(f: => Unit) = {
- println("Executing expectResult2")
- f
- println("Finished expectResult2")
- }
- def sendMessage2(message:AnyRef)(f: => Unit):MessageForActor = {
- println("Executing sendMessage2")
- f
- println("Finished sendMessage2")
- MessageForActor(message)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement