Enabled future-type message sends for reactors.

1 files changed, 47 insertions, 0 deletions

diff --git a/test/files/jvm/replyablereactor.scala b/test/files/jvm/replyablereactor.scala
new file mode 100644
index 0000000000..5c45c7fc54
--- /dev/null
+++ b/test/files/jvm/replyablereactor.scala
@@ -0,0 +1,47 @@
+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 ft = r !! 'hello
+              react {
+                case ft.inputChannel ! msg =>
+                  if (i % 10000 == 0)
+                    println(msg)
+                  if (i >= 50000) {
+                    r ! 'stop
+                    exit()
+                  }
+              }
+            }
+        }
+      }
+    }
+    b.start()
+
+    b ! a
+  }
+}