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

Deduplicate is specific to interception so belongs where it is #25599 (#25665)

Browse source
This commit is contained in:
Johan Andrén 2018-09-21 15:28:03 +02:00 • committed by Arnout Engelen
parent 8c058678ca
commit 16438fcb86
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-actor-typed/src/main/scala/akka/actor/typed/internal/InterceptorImpl.scala
View file

@ -74,7 +74,6 @@ private[akka] final class InterceptorImpl[O, I](val interceptor: BehaviorInterce
} }
private def deduplicate(interceptedResult: Behavior[I], ctx: ActorContext[O]): Behavior[O] = { private def deduplicate(interceptedResult: Behavior[I], ctx: ActorContext[O]): Behavior[O] = {
// FIXME does this same/stopped/unhandled really belong here? Also, it does not work
val started = Behavior.start(interceptedResult, ctx.asInstanceOf[ActorContext[I]]) val started = Behavior.start(interceptedResult, ctx.asInstanceOf[ActorContext[I]])
if (started == UnhandledBehavior || started == SameBehavior || !Behavior.isAlive(started)) { if (started == UnhandledBehavior || started == SameBehavior || !Behavior.isAlive(started)) {
started.asInstanceOf[Behavior[O]] started.asInstanceOf[Behavior[O]]
@ -85,7 +84,7 @@ private[akka] final class InterceptorImpl[O, I](val interceptor: BehaviorInterce
case _ ⇒ false case _ ⇒ false
} }
if (duplicateInterceptExists) started.asInstanceOf[Behavior[O]] // FIXME is this really safe (we know there's a Behavior[O] in there though if (duplicateInterceptExists) started.asInstanceOf[Behavior[O]]
else new InterceptorImpl[O, I](interceptor, started) else new InterceptorImpl[O, I](interceptor, started)
} }
} }