summaryrefslogtreecommitdiff
path: root/test/files/jvm/actmig-PinS_1.scala
diff options
context:
space:
mode:
authorphaller <hallerp@gmail.com>2012-09-29 18:15:37 +0200
committerphaller <hallerp@gmail.com>2012-09-29 18:19:52 +0200
commitb2211a76a6e537cf2e404d424cb643f171818e92 (patch)
tree0fde859c45025594b7205cffe1c29fc37bf9b483 /test/files/jvm/actmig-PinS_1.scala
parentbe49f36154efa78c3dcbeba394aa6ec2b5e764ec (diff)
downloadscala-b2211a76a6e537cf2e404d424cb643f171818e92.tar.gz
scala-b2211a76a6e537cf2e404d424cb643f171818e92.tar.bz2
scala-b2211a76a6e537cf2e404d424cb643f171818e92.zip
SI-6442 - Add ActorDSL object for actor migration kit
Removes MigrationSystem, since ActorDSL replaces it.
Diffstat (limited to 'test/files/jvm/actmig-PinS_1.scala')
-rw-r--r--test/files/jvm/actmig-PinS_1.scala21
1 files changed, 10 insertions, 11 deletions
diff --git a/test/files/jvm/actmig-PinS_1.scala b/test/files/jvm/actmig-PinS_1.scala
index 876688ca75..495852e812 100644
--- a/test/files/jvm/actmig-PinS_1.scala
+++ b/test/files/jvm/actmig-PinS_1.scala
@@ -9,7 +9,7 @@ import scala.concurrent.{ Promise, Await }
object SillyActor {
val startPromise = Promise[Boolean]()
- val ref = MigrationSystem.actorOf(Props(() => new SillyActor, "akka.actor.default-stash-dispatcher"))
+ val ref = ActorDSL.actor(new SillyActor)
}
/* PinS, Listing 32.1: A simple actor
@@ -27,7 +27,7 @@ class SillyActor extends Actor {
object SeriousActor {
val startPromise = Promise[Boolean]()
- val ref = MigrationSystem.actorOf(Props(() => new SeriousActor, "akka.actor.default-stash-dispatcher"))
+ val ref = ActorDSL.actor(new SeriousActor)
}
class SeriousActor extends Actor {
@@ -72,7 +72,7 @@ object Test extends App {
/* PinS, Listing 32.2: An actor that calls receive
*/
- def makeEchoActor(): ActorRef = MigrationSystem.actorOf(Props(() => new Actor {
+ def makeEchoActor(): ActorRef = ActorDSL.actor(new Actor {
def act() {
while (true) {
receive {
@@ -83,20 +83,20 @@ object Test extends App {
}
}
}
- }, "akka.actor.default-stash-dispatcher"))
+ })
/* PinS, page 696
*/
- def makeIntActor(): ActorRef = MigrationSystem.actorOf(Props(() => new Actor {
+ def makeIntActor(): ActorRef = ActorDSL.actor(new Actor {
def act() {
receive {
case x: Int => // I only want Ints
println("Got an Int: " + x)
}
}
- }, "akka.actor.default-stash-dispatcher"))
+ })
- MigrationSystem.actorOf(Props(() => new Actor {
+ ActorDSL.actor(new Actor {
def act() {
trapExit = true
link(SillyActor.ref)
@@ -109,15 +109,14 @@ object Test extends App {
case Exit(_: SeriousActor, _) =>
val seriousPromise2 = Promise[Boolean]()
// PinS, page 694
- val seriousActor2 = MigrationSystem.actorOf(Props(() =>
+ val seriousActor2 = ActorDSL.actor(
new Actor {
def act() {
for (i <- 1 to 5)
println("That is the question.")
seriousPromise2.success(true)
}
- }
- , "akka.actor.default-stash-dispatcher"))
+ })
Await.ready(seriousPromise2.future, 5 seconds)
val echoActor = makeEchoActor()
@@ -136,5 +135,5 @@ object Test extends App {
}
}
}
- }, "akka.actor.default-stash-dispatcher"))
+ })
}