From d063a9fa5162bf6f59b34d653b46534830310a50 Mon Sep 17 00:00:00 2001
From: Philipp Haller <hallerp@gmail.com>
Date: Tue, 21 Jul 2009 17:35:01 +0000
Subject: Enabled synchronous message sends for Replyable...

Enabled synchronous message sends for ReplyableReactor. Added
get(timeout: Long) method to SyncVar.
---
 test/files/jvm/replyablereactor4.scala | 44 ++++++++++++++++++++++++++++++++++
 1 file changed, 44 insertions(+)
 create mode 100644 test/files/jvm/replyablereactor4.scala

(limited to 'test/files/jvm/replyablereactor4.scala')

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
+  }
+}
-- 
cgit v1.2.3