raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

#22662 Partial application for signal management

Browse source
This commit is contained in:
Martynas Mickevičius 2017-04-28 08:29:31 +03:00
parent 6cbd80e86e
commit 8c8683c80d
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-typed/src/main/scala/akka/typed/scaladsl/Actor.scala
View file

@ -274,11 +274,10 @@ object Actor {
* * returning `this` or `Same` designates to reuse the current Behavior
* * returning `Unhandled` keeps the same Behavior and signals that the message was not yet handled
*
* By default, this method returns `Unhandled`.
* By default, partial function is empty and does not handle any signals.
*/
@throws(classOf[Exception])
def onSignal(msg: Signal): Behavior[T] =
Unhandled
def onSignal: PartialFunction[Signal, Behavior[T]] = PartialFunction.empty
}
/**
@ -333,7 +332,7 @@ object Actor {
onMessage: (ActorContext[T], T) ⇒ Behavior[T],
onSignal: PartialFunction[(ActorContext[T], Signal), Behavior[T]] = Behavior.unhandledSignal.asInstanceOf[PartialFunction[(ActorContext[T], Signal), Behavior[T]]])
extends ExtensibleBehavior[T] {
override def receiveSignal(ctx: AC[T], msg: Signal): Behavior[T] = onSignal(ctx, msg)
override def receiveSignal(ctx: AC[T], msg: Signal): Behavior[T] = onSignal.applyOrElse((ctx, msg), Behavior.unhandledSignal.asInstanceOf[PartialFunction[(ActorContext[T], Signal), Behavior[T]]])
override def receiveMessage(ctx: AC[T], msg: T) = onMessage(ctx, msg)
override def toString = s"Immutable(${LineNumbers(onMessage)})"