Enabled synchronous message sends for Replyable...

Enabled synchronous message sends for ReplyableReactor. Added
get(timeout: Long) method to SyncVar.

1 files changed, 44 insertions, 0 deletions

diff --git a/test/files/jvm/replyablereactor4.scala b/test/files/jvm/replyablereactor4.scala
new file mode 100644
index 0000000000..f09e32e356
--- /dev/null
+++ b/test/files/jvm/replyablereactor4.scala
@@ -0,0 +1,44 @@
+import scala.actors._
+import scala.actors.Actor._
+
+class MyActor extends ReplyReactor with ReplyableReactor {
+  def act() {
+    loop {
+      react {
+        case 'hello =>
+          sender ! 'hello
+        case 'stop =>
+          exit()
+      }
+    }
+  }
+}
+
+object Test {
+  def main(args: Array[String]) {
+    val a = new MyActor
+    a.start()
+
+    val b = new Reactor {
+      def act() {
+        react {
+          case r: MyActor =>
+            var i = 0
+            loop {
+              i += 1
+              val msg = r !? (500, 'hello)
+              if (i % 10000 == 0)
+                println(msg)
+              if (i >= 50000) {
+                r ! 'stop
+                exit()
+              }
+            }
+        }
+      }
+    }
+    b.start()
+
+    b ! a
+  }
+}