1 files changed, 135 insertions, 0 deletions
diff --git a/test/files/jvm/actmig-PinS_1.scala b/test/files/jvm/actmig-PinS_1.scala
new file mode 100644
index 0000000000..1fb50567b9
--- /dev/null
+++ b/test/files/jvm/actmig-PinS_1.scala
@@ -0,0 +1,135 @@
+import scala.actors._
+import scala.concurrent.util.duration._
+import scala.concurrent.{ Promise, Await }
+
+object SillyActor {
+  val startPromise = Promise[Boolean]()
+  val ref = MigrationSystem.actorOf(Props(() => new SillyActor, "akka.actor.default-stash-dispatcher"))
+}
+
+/* PinS, Listing 32.1: A simple actor
+ */
+class SillyActor extends Actor {
+
+  def act() {
+    Await.ready(SillyActor.startPromise.future, 5 seconds)
+    for (i <- 1 to 5)
+      println("I'm acting!")
+
+    println("Post stop")
+  }
+}
+
+object SeriousActor {
+  val startPromise = Promise[Boolean]()
+  val ref = MigrationSystem.actorOf(Props(() => new SeriousActor, "akka.actor.default-stash-dispatcher"))
+}
+
+class SeriousActor extends Actor {
+  def act() {
+    // used to make this test deterministic
+    Await.ready(SeriousActor.startPromise.future, 5 seconds)
+    for (i <- 1 to 5)
+      println("To be or not to be.")
+  }
+}
+
+/* PinS, Listing 32.3: An actor that calls react
+ */
+object NameResolver extends Actor {
+  import java.net.{ InetAddress, UnknownHostException }
+
+  def act() {
+    react {
+      case (name: String, actor: Actor) =>
+        actor ! getIp(name)
+        act()
+      case "EXIT" =>
+        println("Name resolver exiting.")
+      // quit
+      case msg =>
+        println("Unhandled message: " + msg)
+        act()
+    }
+  }
+
+  def getIp(name: String): Option[InetAddress] = {
+    try {
+      Some(InetAddress.getByName(name))
+    } catch {
+      case _: UnknownHostException => None
+    }
+  }
+
+}
+
+object Test extends App {
+
+  /* PinS, Listing 32.2: An actor that calls receive
+   */
+  def makeEchoActor(): ActorRef = MigrationSystem.actorOf(Props(() => new Actor {
+    def act() {
+      while (true) {
+        receive {
+          case 'stop =>
+            exit()
+          case msg =>
+            println("received message: " + msg)
+        }
+      }
+    }
+  }, "akka.actor.default-stash-dispatcher"))
+
+  /* PinS, page 696
+   */
+  def makeIntActor(): ActorRef = MigrationSystem.actorOf(Props(() => new Actor {
+    def act() {
+      receive {
+        case x: Int => // I only want Ints
+          println("Got an Int: " + x)
+      }
+    }
+  }, "akka.actor.default-stash-dispatcher"))
+
+  MigrationSystem.actorOf(Props(() => new Actor {
+    def act() {
+      trapExit = true
+      link(SillyActor.ref)
+      SillyActor.startPromise.success(true)
+      react {
+        case Exit(_: SillyActor, _) =>
+          link(SeriousActor.ref)
+          SeriousActor.startPromise.success(true)
+          react {
+            case Exit(_: SeriousActor, _) =>
+              val seriousPromise2 = Promise[Boolean]()
+              // PinS, page 694
+              val seriousActor2 = MigrationSystem.actorOf(Props(() =>
+                new Actor {
+                  def act() {
+                    for (i <- 1 to 5)
+                      println("That is the question.")
+                    seriousPromise2.success(true)
+                  }
+                }
+              , "akka.actor.default-stash-dispatcher"))
+
+              Await.ready(seriousPromise2.future, 5 seconds)
+              val echoActor = makeEchoActor()
+              link(echoActor)
+              echoActor ! "hi there"
+              echoActor ! 15
+              echoActor ! 'stop
+              react {
+                case Exit(_, _) =>
+                  val intActor = makeIntActor()
+                  intActor ! "hello"
+                  intActor ! math.Pi
+                  // only the following send leads to output
+                  intActor ! 12
+              }
+          }
+      }
+    }
+  }, "akka.actor.default-stash-dispatcher"))
+}