Merge pull request #21155 from andreaTP/unsVis
=act change Unsubscribers visibility.
This commit is contained in:
commit
0d40f61dc4
2 changed files with 2 additions and 2 deletions
|
|
@ -12,7 +12,7 @@ import java.util.concurrent.atomic.AtomicInteger
|
|||
*
|
||||
* Watches all actors which subscribe on the given event stream, and unsubscribes them from it when they are Terminated.
|
||||
*/
|
||||
private[akka] class ActorClassificationUnsubscriber(bus: ManagedActorClassification, debug: Boolean) extends Actor with Stash {
|
||||
protected[akka] class ActorClassificationUnsubscriber(bus: ManagedActorClassification, debug: Boolean) extends Actor with Stash {
|
||||
|
||||
import ActorClassificationUnsubscriber._
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@ import java.util.concurrent.atomic.AtomicInteger
|
|||
* subscribe calls * because of the need of linearizing the history message sequence and the possibility of sometimes
|
||||
* watching a few actors too much - we opt for the 2nd choice here.
|
||||
*/
|
||||
private[akka] class EventStreamUnsubscriber(eventStream: EventStream, debug: Boolean = false) extends Actor {
|
||||
protected[akka] class EventStreamUnsubscriber(eventStream: EventStream, debug: Boolean = false) extends Actor {
|
||||
|
||||
import EventStreamUnsubscriber._
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue