gistfile1.scala

import akka.actor.{Props, ActorSystem, Actor}
import akka.pattern.ask
import akka.util.Timeout
import scala.concurrent.duration._

object Testing extends App {
  case class Inc(n: Int)

  class CounterActor extends Actor {
    private var state = 0
    def receive = {
      case Inc(n) =>
        state += n
        sender() ! state
    }
  }

  val system = ActorSystem()
  val counterActor = system.actorOf(Props[CounterActor])

  implicit val timeout = Timeout(10.seconds)
  import system.dispatcher

  (counterActor ? Inc(20)).mapTo[Int].foreach(println)
  (counterActor ? Inc(5)).mapTo[Int].foreach(println)

  Thread.sleep(1000L)
  system.shutdown()
}