Additional Actor Migration Tests.

Review by @phaller.

1 files changed, 74 insertions, 0 deletions

diff --git a/test/files/jvm/actmig-public-methods.scala b/test/files/jvm/actmig-public-methods.scala
new file mode 100644
index 0000000000..58d7a1a9d4
--- /dev/null
+++ b/test/files/jvm/actmig-public-methods.scala
@@ -0,0 +1,74 @@
+/**
+ * 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.collection.mutable.ArrayBuffer
+import scala.actors.Actor._
+import scala.actors._
+import scala.actors.migration.MigrationSystem
+import scala.util.continuations._
+import java.util.concurrent.{ TimeUnit, CountDownLatch }
+
+object Test {
+  val NUMBER_OF_TESTS = 6
+
+  // used for sorting non-deterministic output
+  val buff = ArrayBuffer[String]()
+  val latch = new CountDownLatch(NUMBER_OF_TESTS)
+  val toStop = ArrayBuffer[Actor]()
+
+  def append(v: String) = synchronized {
+    buff += v
+  }
+
+  def main(args: Array[String]) = {
+
+    val respActor = actor {
+      loop {
+        react {
+          case (x: String, time: Long) =>
+            Thread.sleep(time)
+            reply(x + " after " + time)
+          case str: String =>
+            append(str)
+            latch.countDown()
+          case _ => exit()
+        }
+      }
+    }
+
+    toStop += respActor
+
+    respActor ! ("bang")
+
+    val res1 = respActor !? (("bang qmark", 0L))
+    append(res1.toString)
+    latch.countDown()
+
+    val res2 = respActor !? (5000, ("bang qmark", 1L))
+    append(res2.toString)
+    latch.countDown()
+
+    // this one should timeout
+    val res21 = respActor !? (1, ("bang qmark", 5000L))
+    append(res21.toString)
+    latch.countDown()
+
+    val fut1 = respActor !! (("bang bang in the future", 0L))
+    append(fut1().toString())
+    latch.countDown()
+
+    val fut2 = respActor !! (("typed bang bang in the future", 0L), { case x: String => x })
+    append(fut2())
+    latch.countDown()
+
+    // output
+    latch.await(10, TimeUnit.SECONDS)
+    if (latch.getCount() > 0) {
+      println("Error: Tasks have not finished!!!")
+    }
+
+    buff.sorted.foreach(println)
+    toStop.foreach(_ ! 'stop)
+  }
+}
\ No newline at end of file