From 6641b30a8fa7fa53cfcfae9d25f1664239c33969 Mon Sep 17 00:00:00 2001 From: Heiko Seeberger Date: Mon, 11 Apr 2011 14:31:27 +0200 Subject: [PATCH] Another minor coding style correction in akka-tutorial. --- akka-docs/manual/getting-started-first.rst | 16 ++++++++-------- .../akka-tutorial-first/src/main/scala/Pi.scala | 6 +++--- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/akka-docs/manual/getting-started-first.rst b/akka-docs/manual/getting-started-first.rst index e5f7a4ba1f..2f3f9e518f 100644 --- a/akka-docs/manual/getting-started-first.rst +++ b/akka-docs/manual/getting-started-first.rst @@ -236,10 +236,10 @@ Creating the master The master actor is a little bit more involved. In its constructor we need to create the workers (the ``Worker`` actors) and start them. We will also wrap them in a load-balancing router to make it easier to spread out the work evenly between the workers. Let's do that first:: // create the workers - val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start) + val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start()) // wrap them with a load-balancing router - val router = Routing.loadBalancerActor(CyclicIterator(workers)).start + val router = Routing.loadBalancerActor(CyclicIterator(workers)).start() As you can see we are using the ``actorOf`` factory method to create actors, this method returns as an ``ActorRef`` which is a reference to our newly created actor. This method is available in the ``Actor`` object but is usually imported:: @@ -261,10 +261,10 @@ Let's now write the master actor:: var start: Long = _ // create the workers - val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start) + val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start()) // wrap them with a load-balancing router - val router = Routing.loadBalancerActor(CyclicIterator(workers)).start + val router = Routing.loadBalancerActor(CyclicIterator(workers)).start() def receive = { ... } @@ -332,7 +332,7 @@ Now the only thing that is left to implement is the runner that should bootstrap val latch = new CountDownLatch(1) // create the master - val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start + val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start() // start the calculation master ! Calculate @@ -398,10 +398,10 @@ But before we package it up and run it, let's take a look at the full code now, var start: Long = _ // create the workers - val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start) + val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start()) // wrap them with a load-balancing router - val router = Routing.loadBalancerActor(CyclicIterator(workers)).start + val router = Routing.loadBalancerActor(CyclicIterator(workers)).start() // message handler def receive = { @@ -443,7 +443,7 @@ But before we package it up and run it, let's take a look at the full code now, val latch = new CountDownLatch(1) // create the master - val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start + val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start() // start the calculation master ! Calculate diff --git a/akka-tutorials/akka-tutorial-first/src/main/scala/Pi.scala b/akka-tutorials/akka-tutorial-first/src/main/scala/Pi.scala index 3107bc280a..c31f8ee2f6 100644 --- a/akka-tutorials/akka-tutorial-first/src/main/scala/Pi.scala +++ b/akka-tutorials/akka-tutorial-first/src/main/scala/Pi.scala @@ -80,10 +80,10 @@ object Pi extends App { var start: Long = _ // create the workers - val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start) + val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start()) // wrap them with a load-balancing router - val router = Routing.loadBalancerActor(CyclicIterator(workers)).start + val router = Routing.loadBalancerActor(CyclicIterator(workers)).start() // message handler def receive = { @@ -125,7 +125,7 @@ object Pi extends App { val latch = new CountDownLatch(1) // create the master - val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start + val master = actorOf(new Master(nrOfWorkers, nrOfMessages, nrOfElements, latch)).start() // start the calculation master ! Calculate