java.lang.Object
- akka.event.EventStreamUnsubscriber

All Implemented Interfaces:

Actor
```
public class EventStreamUnsubscriber
extends java.lang.Object
implements Actor
```
INTERNAL API
Watches all actors which subscribe on the given eventStream, and unsubscribes them from it when they are Terminated.
Assumptions note: We do not guarantee happens-before in the EventStream when 2 threads subscribe(a) / unsubscribe(a) on the same actor, thus the messages sent to this actor may appear to be reordered - this is fine, because the worst-case is starting to needlessly watch the actor which will not cause trouble for the stream. This is a trade-off between slowing down 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.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`static class`	`EventStreamUnsubscriber.Register`
`static class`	`EventStreamUnsubscriber.Register$`
`static class`	`EventStreamUnsubscriber.UnregisterIfNoMoreSubscribedChannels`
`static class`	`EventStreamUnsubscriber.UnregisterIfNoMoreSubscribedChannels$`

Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors
Constructor Description

EventStreamUnsubscriber(EventStream eventStream, boolean debug)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static boolean`	`$lessinit$greater$default$2()`
`protected void`	`akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)`
`protected void`	`akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)`	The 'self' field holds the ActorRef for this actor.
`ActorContext`	`context()`	Scala API: Stores the context for this actor, including self, and sender.
`void`	`preStart()`	User overridable callback.
`scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>`	`receive()`	Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
`ActorRef`	`self()`	The 'self' field holds the ActorRef for this actor.
`static ActorRef`	`start(ActorSystem system, EventStream stream)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, sender, supervisorStrategy, unhandled

- Constructor Detail
  - EventStreamUnsubscriber
```
public EventStreamUnsubscriber(EventStream eventStream,
                               boolean debug)
```
- Method Detail
  - $lessinit$greater$default$2
```
public static boolean $lessinit$greater$default$2()
```
  - start
```
public static ActorRef start(ActorSystem system,
                             EventStream stream)
```
  - context
```
public ActorContext context()
```
    Description copied from interface: Actor
    
    Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.
    WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
    ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.
    
    Specified by:
    
    context in interface Actor
    
    Returns:
    
    (undocumented)
  - self
```
public final ActorRef self()
```
    Description copied from interface: Actor
    The 'self' field holds the ActorRef for this actor.
    Can be used to send messages to itself:
    self ! message
    Specified by:
    
    self in interface Actor
    
    Returns:
    
    (undocumented)
  - akka$actor$Actor$_setter_$context_$eq
```
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
```
    Specified by:
    
    akka$actor$Actor$_setter_$context_$eq in interface Actor
  - akka$actor$Actor$_setter_$self_$eq
```
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
```
    Description copied from interface: Actor
    The 'self' field holds the ActorRef for this actor.
    Can be used to send messages to itself:
    self ! message
    Specified by:
    
    akka$actor$Actor$_setter_$self_$eq in interface Actor
    
    Parameters:
    
    x$1 - (undocumented)
  - preStart
```
public void preStart()
```
    Description copied from interface: Actor
    
    User overridable callback.
    Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
    
    Specified by:
    
    preStart in interface Actor
  - receive
```
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
```
    Description copied from interface: Actor
    
    Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
    
    Specified by:
    
    receive in interface Actor
    
    Returns:
    
    (undocumented)

Class EventStreamUnsubscriber

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface akka.actor.Actor

Constructor Detail

EventStreamUnsubscriber

Method Detail

$lessinit$greater$default$2

start

context

self

akka$actor$Actor$_setter_$context_$eq

akka$actor$Actor$_setter_$self_$eq

preStart

receive