EventStream

All Implemented Interfaces:: ActorEventBus, EventBus, LoggingBus, SubchannelClassification

public class EventStream
extends java.lang.Object
implements LoggingBus, SubchannelClassification

Constructors
Constructor and Description
`EventStream(ActorSystem sys)`
`EventStream(ActorSystem sys, boolean debug)`
`EventStream(boolean debug)`

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`protected java.lang.Class<?>`	`classify(java.lang.Object event)`
`static EventStream`	`fromActorSystem(ActorSystem system)`
`boolean`	`initUnsubscriber(ActorRef unsubscriber)` INTERNAL API
`protected void`	`publish(java.lang.Object event, ActorRef subscriber)`
`void`	`startUnsubscriber()` ''Must'' be called after actor system is "ready".
`protected java.lang.Object`	`subclassification()` The logic to form sub-class hierarchy
`boolean`	`subscribe(ActorRef subscriber, java.lang.Class<?> channel)`
`void`	`unsubscribe(ActorRef subscriber)`
`boolean`	`unsubscribe(ActorRef subscriber, java.lang.Class<?> channel)`

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

Methods inherited from interface akka.event.EventBus
publish, subscribe, unsubscribe, unsubscribe

public EventStream(ActorSystem sys,
                   boolean debug)

public static EventStream fromActorSystem(ActorSystem system)

protected java.lang.Class<?> classify(java.lang.Object event)

protected void publish(java.lang.Object event,
                       ActorRef subscriber)

public boolean subscribe(ActorRef subscriber,
                         java.lang.Class<?> channel)

public boolean unsubscribe(ActorRef subscriber,
                           java.lang.Class<?> channel)

public void unsubscribe(ActorRef subscriber)

startUnsubscriber
```
public void startUnsubscriber()
```
''Must'' be called after actor system is "ready". Starts system actor that takes care of unsubscribing subscribers that have terminated.

Class EventStream