Class FanoutProcessorImpl

    • Method Detail

      • sender

        public static final ActorRef sender()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • initialPhase

        public static final void initialPhase​(int waitForUpstream,
                                              TransferPhase andThen)
      • waitForUpstreams

        public static final void waitForUpstreams​(int waitForUpstream)
      • gotUpstreamSubscription

        public static void gotUpstreamSubscription()
      • nextPhase

        public static final void nextPhase​(TransferPhase phase)
      • isPumpFinished

        public static final boolean isPumpFinished()
      • pump

        public static final void pump()
      • primaryInputs

        protected static Inputs primaryInputs()
      • activeReceive

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> activeReceive()
      • onError

        protected static void onError​(java.lang.Throwable e)
      • pumpFailed

        public static void pumpFailed​(java.lang.Throwable e)
      • postStop

        public static void postStop()
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
      • akka$stream$impl$Pump$$transferState

        public static TransferState akka$stream$impl$Pump$$transferState()
      • akka$stream$impl$Pump$$transferState_$eq

        public static void akka$stream$impl$Pump$$transferState_$eq​(TransferState x$1)
      • akka$stream$impl$Pump$$currentAction

        public static scala.Function0<scala.runtime.BoxedUnit> akka$stream$impl$Pump$$currentAction()
      • akka$stream$impl$Pump$$currentAction_$eq

        public static void akka$stream$impl$Pump$$currentAction_$eq​(scala.Function0<scala.runtime.BoxedUnit> x$1)
      • completedPhase

        protected static final TransferPhase completedPhase()
      • akka$stream$impl$Pump$_setter_$completedPhase_$eq

        protected static final void akka$stream$impl$Pump$_setter_$completedPhase_$eq​(TransferPhase x$1)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • self

        public static final ActorRef self()
      • akka$actor$Actor$_setter_$context_$eq

        protected static void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
      • akka$actor$Actor$_setter_$self_$eq

        protected static final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
      • afterFlush

        public void afterFlush()