From 7257dc5d86171d4f922e748a26a209aa29f4db3e Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Wed, 30 May 2012 17:37:44 +0200 Subject: [PATCH] Minor code formatting --- .../src/main/scala/akka/actor/ActorCell.scala | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/akka-actor/src/main/scala/akka/actor/ActorCell.scala b/akka-actor/src/main/scala/akka/actor/ActorCell.scala index 23cd796ad2..3db70d5735 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorCell.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorCell.scala @@ -727,10 +727,9 @@ private[akka] class ActorCell( val terminated = Terminated(self)(stopped = true) try { watchedBy foreach { - watcher ⇒ - try watcher.tell(terminated, self) catch { - case NonFatal(t) ⇒ system.eventStream.publish(Error(t, self.path.toString, clazz(a), "deathwatch")) - } + watcher ⇒ try watcher.tell(terminated, self) catch { + case NonFatal(t) ⇒ system.eventStream.publish(Error(t, self.path.toString, clazz(a), "deathwatch")) + } } } finally watchedBy = emptyActorRefSet } @@ -738,10 +737,9 @@ private[akka] class ActorCell( if (!watching.isEmpty) { try { watching foreach { - case watchee: InternalActorRef ⇒ - try watchee.sendSystemMessage(Unwatch(watchee, self)) catch { - case NonFatal(t) ⇒ system.eventStream.publish(Error(t, self.path.toString, clazz(a), "deathwatch")) - } + case watchee: InternalActorRef ⇒ try watchee.sendSystemMessage(Unwatch(watchee, self)) catch { + case NonFatal(t) ⇒ system.eventStream.publish(Error(t, self.path.toString, clazz(a), "deathwatch")) + } } } finally watching = emptyActorRefSet }