Merge pull request #1394 from vjovanov/amk/ActorRef

Moving ActorRef API to scala.concurrent.

1 files changed, 48 insertions, 0 deletions

diff --git a/test/files/jvm/actmig-react-within.scala b/test/files/jvm/actmig-react-within.scala
new file mode 100644
index 0000000000..43350ef120
--- /dev/null
+++ b/test/files/jvm/actmig-react-within.scala
@@ -0,0 +1,48 @@
+/**
+ * NOTE: Code snippets from this test are included in the Actor Migration Guide. In case you change
+ * code in these tests prior to the 2.10.0 release please send the notification to @vjovanov.
+ */
+import scala.actors.migration.MigrationSystem._
+import scala.actors.Actor._
+import scala.actors._
+import scala.actors.migration._
+import java.util.concurrent.{ TimeUnit, CountDownLatch }
+import scala.collection.mutable.ArrayBuffer
+import scala.concurrent.duration._
+import scala.concurrent.{ Promise, Await }
+
+object Test {
+  val finished = Promise[Boolean]
+
+  def testReactWithin() = {
+    val sActor = actor {
+      loop {
+        reactWithin(1) {
+          case scala.actors.TIMEOUT =>
+            println("received")
+            exit()
+          case _ =>
+            println("Should not occur.")
+        }
+      }
+    }
+
+    val myActor = MigrationSystem.actorOf(Props(() => new StashingActor {
+      context.setReceiveTimeout(1 millisecond)
+      def receive = {
+        case ReceiveTimeout =>
+          println("received")
+          finished.success(true)
+          context.stop(self)
+        case _ =>
+          println("Should not occur.")
+      }
+    }, "default-stashing-dispatcher"))
+  }
+
+  def main(args: Array[String]) = {
+    testReactWithin()
+    Await.ready(finished.future, 5 seconds)
+  }
+
+}