From f14c3081b4fb5f666c07f123b9f40cb8db52ff37 Mon Sep 17 00:00:00 2001 From: Philipp Haller Date: Tue, 27 Feb 2007 13:56:11 +0000 Subject: Cleaned-up actor examples --- docs/examples/actors/links.scala | 8 ++++---- docs/examples/actors/looping.scala | 2 +- docs/examples/actors/producers.scala | 7 +++---- 3 files changed, 8 insertions(+), 9 deletions(-) (limited to 'docs') diff --git a/docs/examples/actors/links.scala b/docs/examples/actors/links.scala index 149f6db159..05311a4d51 100644 --- a/docs/examples/actors/links.scala +++ b/docs/examples/actors/links.scala @@ -1,6 +1,6 @@ package examples.actors -import scala.actors.{Actor, Exit} +import scala.actors.Actor import scala.actors.Actor._ object links extends Application { @@ -22,9 +22,9 @@ object links extends Application { link(a) loop { receive { - case ex @ Exit(from, reason) => + case ex @ ('EXIT, from, reason) => Console.println("Actor " + n + " received " + ex) - exit("finished") + exit('finished) case any => { Console.println("Actor " + n + " received " + any) a ! any @@ -38,7 +38,7 @@ object links extends Application { receive { case Stop => Console.println("Last actor now exiting") - exit("abnormal") + exit('abnormal) case any => Console.println("Last actor received " + any) top1() diff --git a/docs/examples/actors/looping.scala b/docs/examples/actors/looping.scala index 805d501d11..68a016600b 100644 --- a/docs/examples/actors/looping.scala +++ b/docs/examples/actors/looping.scala @@ -16,7 +16,7 @@ object looping extends Application { scala.Console.println("received A") else { scala.Console.println("received last A") - exit("finished") + exit('finished) } } } diff --git a/docs/examples/actors/producers.scala b/docs/examples/actors/producers.scala index 7e8e34bf48..c45ed63ed3 100644 --- a/docs/examples/actors/producers.scala +++ b/docs/examples/actors/producers.scala @@ -38,15 +38,14 @@ abstract class Producer[T] { } private val coordinator: Actor = actor { - var continue = true - while (continue) { - receive { + loop { + react { case Next => producer ! Next reply { receive { case x: Option[_] => x } } - case Stop => continue = false + case Stop => exit('stop) } } } -- cgit v1.2.3