Event stream should unsubscribe terminated listeners
We could add a system actor that watches event stream listeners and unsubscribes them on termination.
If this is not urgent, I'd love to give it a try.
If this is not urgent, I'd love to give it a try.
Leave a comment
on 2013-10-02 00:56 *
By Heiko Seeberger
Hmm, I gave it a try, but it's hard!
How can I create a (system) actor which I "inject" into the `EventStream`, when the latter is initialized before the `systemGuardian`?
Da beißt sich die Katze in den Schwanz!
How can I create a (system) actor which I "inject" into the `EventStream`, when the latter is initialized before the `systemGuardian`?
Da beißt sich die Katze in den Schwanz!
on 2013-10-08 02:52 *
By Patrik Nordwall
yes, that is a good point.
I'm not sure what is best, but EventStream is not immutable anyway so you could add a method to set/initialize the actor afterwards. I think the safe point to create such an actor is in _start in ActorSystemImpl
I'm not sure what is best, but EventStream is not immutable anyway so you could add a method to set/initialize the actor afterwards. I think the safe point to create such an actor is in _start in ActorSystemImpl
PR here: https://github.com/akka/akka/pull/2011 // reviewed by team