Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

49 lines (43 sloc) 1.312 kb
/**
* NOTE: Code snippets from this test are included in the Actor Migration Guide. In case you change
* code in these tests prior to the 2.10.0 release please send the notification to @vjovanov.
*/
import scala.actors.migration.MigrationSystem._
import scala.actors.Actor._
import scala.actors._
import scala.actors.migration._
import java.util.concurrent.{ TimeUnit, CountDownLatch }
import scala.collection.mutable.ArrayBuffer
import scala.concurrent.duration._
import scala.concurrent.{ Promise, Await }
object Test {
val finished = Promise[Boolean]
def testReactWithin() = {
val sActor = actor {
loop {
reactWithin(1) {
case scala.actors.TIMEOUT =>
println("received")
exit()
case _ =>
println("Should not occur.")
}
}
}
val myActor = MigrationSystem.actorOf(Props(() => new StashingActor {
context.setReceiveTimeout(1 millisecond)
def receive = {
case ReceiveTimeout =>
println("received")
finished.success(true)
context.stop(self)
case _ =>
println("Should not occur.")
}
}, "default-stashing-dispatcher"))
}
def main(args: Array[String]) = {
testReactWithin()
Await.ready(finished.future, 5 seconds)
}
}
Jump to Line
Something went wrong with that request. Please try again.