Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import akka.actor._
- case class Ping(n:Int)
- case class Pong(n:Int)
- class Player extends Actor {
- def receive = {
- case Ping(n) =>
- println("Ping")
- if(n == 1)
- {
- println("Kończymy grę")
- context.system.terminate()
- }
- else
- sender ! Pong(n - 1)
- case Pong(n) =>
- println("Pong")
- if(n == 1)
- {
- println("Kończymy grę")
- context.system.terminate()
- }
- else
- sender ! Ping(n - 1)
- case _ => new RuntimeException("Nieobsługiwany komunikat")
- }
- }
- object Zad1 {
- def main(args:Array[String]) = {
- val system = ActorSystem("System")
- val player1 = system.actorOf(Props[Player])
- val player2 = system.actorOf(Props[Player])
- player1.tell(Ping(10),player2)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement