Package akka.event

Class EventStream

    • Constructor Detail

      • EventStream

        public EventStream​(ActorSystem sys,
                           boolean debug)
    • Method Detail

      • classify

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

        public final boolean initUnsubscriber​(ActorRef unsubscriber)
        INTERNAL API
        Parameters:
        unsubscriber - (undocumented)
        Returns:
        (undocumented)
      • publish

        protected void publish​(java.lang.Object event,
                               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.
      • subscribe

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

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

        public void unsubscribe​(ActorRef subscriber)