Reactor now has type parameter.

1 files changed, 73 insertions, 0 deletions

diff --git a/test/files/jvm/actor-getstate.scala b/test/files/jvm/actor-getstate.scala
new file mode 100644
index 0000000000..9de3247653
--- /dev/null
+++ b/test/files/jvm/actor-getstate.scala
@@ -0,0 +1,73 @@
+import scala.actors.{Reactor, Actor, TIMEOUT}
+
+object Test {
+
+  def assert(cond: => Boolean) {
+    if (!cond)
+      println("FAIL")
+  }
+
+  def main(args: Array[String]) {
+    val a = new Reactor[Any] {
+      def act() {
+        assert(getState == Actor.State.Runnable)
+        react {
+          case 'go =>
+            println("OK")
+        }
+      }
+    }
+    assert(a.getState == Actor.State.New)
+
+    a.start()
+    Thread.sleep(100)
+    assert(a.getState == Actor.State.Suspended)
+
+    a ! 'go
+    Thread.sleep(100)
+    assert(a.getState == Actor.State.Terminated)
+
+    val b = new Actor {
+      def act() {
+        assert(getState == Actor.State.Runnable)
+        react {
+          case 'go =>
+            reactWithin(100000) {
+              case TIMEOUT =>
+              case 'go =>
+                receive {
+                  case 'go =>
+                }
+                receiveWithin(100000) {
+                  case TIMEOUT =>
+                  case 'go =>
+                    println("OK")
+                }
+            }
+        }
+      }
+    }
+    assert(b.getState == Actor.State.New)
+
+    b.start()
+    Thread.sleep(100)
+    assert(b.getState == Actor.State.Suspended)
+
+    b ! 'go
+    Thread.sleep(100)
+    assert(b.getState == Actor.State.TimedSuspended)
+
+    b ! 'go
+    Thread.sleep(100)
+    assert(b.getState == Actor.State.Blocked)
+
+    b ! 'go
+    Thread.sleep(100)
+    assert(b.getState == Actor.State.TimedBlocked)
+
+    b ! 'go
+    Thread.sleep(100)
+    assert(b.getState == Actor.State.Terminated)
+  }
+
+}