From 7bae3082aa79997367ec471dc67994ab07b20bd4 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Wed, 22 Jan 2014 09:18:20 +0100 Subject: [PATCH] =doc #3102 Remove ComposableActor doc sample --- akka-docs/rst/scala/actors.rst | 4 -- .../scala/code/docs/actor/ActorDocSpec.scala | 55 ------------------- 2 files changed, 59 deletions(-) diff --git a/akka-docs/rst/scala/actors.rst b/akka-docs/rst/scala/actors.rst index dde8fa8779..5bce6269e5 100644 --- a/akka-docs/rst/scala/actors.rst +++ b/akka-docs/rst/scala/actors.rst @@ -889,10 +889,6 @@ extend that, either through inheritance or delegation, is to use .. includecode:: code/docs/actor/ActorDocSpec.scala#receive-orElse -Or: - -.. includecode:: code/docs/actor/ActorDocSpec.scala#receive-orElse2 - Initialization patterns ======================= diff --git a/akka-docs/rst/scala/code/docs/actor/ActorDocSpec.scala b/akka-docs/rst/scala/code/docs/actor/ActorDocSpec.scala index daf8bc554c..c4bffa541d 100644 --- a/akka-docs/rst/scala/code/docs/actor/ActorDocSpec.scala +++ b/akka-docs/rst/scala/code/docs/actor/ActorDocSpec.scala @@ -553,59 +553,4 @@ class ActorDocSpec extends AkkaSpec(Map("akka.loglevel" -> "INFO")) { }) } - //#receive-orElse2 - class PartialFunctionBuilder[A, B] { - import scala.collection.immutable.Vector - - // Abbreviate to make code fit - type PF = PartialFunction[A, B] - - private var pfsOption: Option[Vector[PF]] = Some(Vector.empty) - - private def mapPfs[C](f: Vector[PF] => (Option[Vector[PF]], C)): C = { - pfsOption.fold(throw new IllegalStateException("Already built"))(f) match { - case (newPfsOption, result) => { - pfsOption = newPfsOption - result - } - } - } - - def +=(pf: PF): Unit = - mapPfs { case pfs => (Some(pfs :+ pf), ()) } - - def result(): PF = - mapPfs { case pfs => (None, pfs.foldLeft[PF](Map.empty) { _ orElse _ }) } - } - - trait ComposableActor extends Actor { - protected lazy val receiveBuilder = new PartialFunctionBuilder[Any, Unit] - final def receive = receiveBuilder.result() - } - - trait TheirComposableActor extends ComposableActor { - receiveBuilder += { - case "foo" => sender() ! "foo received" - } - } - - class MyComposableActor extends TheirComposableActor { - receiveBuilder += { - case "bar" => sender() ! "bar received" - } - } - //#receive-orElse2 - - "using ComposableActor" in { - val composed = system.actorOf(Props(classOf[MyComposableActor], this)) - implicit val me = testActor - composed ! "foo" - expectMsg("foo received") - composed ! "bar" - expectMsg("bar received") - EventFilter.warning(pattern = ".*unhandled message from.*baz", occurrences = 1) intercept { - composed ! "baz" - } - } - }