From 64342a3d920ea055739f94d1f10119bcfeabd12e Mon Sep 17 00:00:00 2001 From: Philipp Haller Date: Tue, 21 Jul 2009 12:21:56 +0000 Subject: Enabled future-type message sends for reactors. --- test/files/jvm/replyablereactor.scala | 47 +++++++++++++++++++++++++++++++++++ 1 file changed, 47 insertions(+) create mode 100644 test/files/jvm/replyablereactor.scala (limited to 'test/files/jvm/replyablereactor.scala') 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 + } +} -- cgit v1.2.3