diff options
author | Philipp Haller <hallerp@gmail.com> | 2010-03-08 15:01:53 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2010-03-08 15:01:53 +0000 |
commit | 57261cf375a8442a267b918ed582af526f8491fa (patch) | |
tree | 7198dd7ee431697803bf865ccb7343aa2f939664 /test/files/jvm/reactor-producer-consumer.scala | |
parent | 13f24056a444fd5038cebdb294a0959bfe979492 (diff) | |
download | scala-57261cf375a8442a267b918ed582af526f8491fa.tar.gz scala-57261cf375a8442a267b918ed582af526f8491fa.tar.bz2 scala-57261cf375a8442a267b918ed582af526f8491fa.zip |
Reactor now has type parameter.
Diffstat (limited to 'test/files/jvm/reactor-producer-consumer.scala')
-rw-r--r-- | test/files/jvm/reactor-producer-consumer.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/test/files/jvm/reactor-producer-consumer.scala b/test/files/jvm/reactor-producer-consumer.scala index 946e1561ce..0d33043fc6 100644 --- a/test/files/jvm/reactor-producer-consumer.scala +++ b/test/files/jvm/reactor-producer-consumer.scala @@ -2,10 +2,10 @@ import scala.actors.Reactor object Test { case class Stop() - case class Get(from: Reactor) + case class Get(from: Reactor[Any]) case class Put(x: Int) - class UnboundedBuffer extends Reactor { + class UnboundedBuffer extends Reactor[Any] { def act() { react { case Stop() => @@ -20,7 +20,7 @@ object Test { } } - class Producer(buf: UnboundedBuffer, n: Int, delay: Long, parent: Reactor) extends Reactor { + class Producer(buf: UnboundedBuffer, n: Int, delay: Long, parent: Reactor[Any]) extends Reactor[Any] { def act() { var i = 0 while (i < n) { @@ -32,7 +32,7 @@ object Test { } } - class Consumer(buf: UnboundedBuffer, n: Int, delay: Long, parent: Reactor) extends Reactor { + class Consumer(buf: UnboundedBuffer, n: Int, delay: Long, parent: Reactor[Any]) extends Reactor[Any] { val step = n / 10 var i = 0 def act() { @@ -53,7 +53,7 @@ object Test { } def main(args: Array[String]) { - val parent = new Reactor { + val parent = new Reactor[Any] { def act() { val buffer = new UnboundedBuffer buffer.start() |