Package akka.stream.impl
Class FanoutProcessorImpl
- java.lang.Object
-
- akka.stream.impl.ActorProcessorImpl
-
- akka.stream.impl.FanoutProcessorImpl
-
- All Implemented Interfaces:
Actor
,ActorLogging
,Pump
public class FanoutProcessorImpl extends ActorProcessorImpl
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.impl.ActorProcessorImpl
ActorProcessorImpl.SubscriptionTimeout$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description FanoutProcessorImpl(Attributes attributes)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterFlush()
void
postStop()
User overridable callback.FanoutOutputs
primaryOutputs()
static Props
props(Attributes attributes)
void
pumpFinished()
TransferPhase
running()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
subTimeoutHandling()
scala.concurrent.duration.FiniteDuration
timeout()
StreamSubscriptionTimeoutTerminationMode
timeoutMode()
OptionVal<Cancellable>
timeoutTimer()
-
Methods inherited from class akka.stream.impl.ActorProcessorImpl
activeReceive, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$stream$impl$Pump$_setter_$completedPhase_$eq, completedPhase, context, fail, onError, postRestart, primaryInputs, pumpFailed, receive, self
-
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, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.stream.impl.Pump
currentAction_$eq, gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, transferState_$eq, waitForUpstreams
-
-
-
-
Constructor Detail
-
FanoutProcessorImpl
public FanoutProcessorImpl(Attributes attributes)
-
-
Method Detail
-
props
public static Props props(Attributes attributes)
-
timeout
public scala.concurrent.duration.FiniteDuration timeout()
-
timeoutMode
public StreamSubscriptionTimeoutTerminationMode timeoutMode()
-
timeoutTimer
public OptionVal<Cancellable> timeoutTimer()
-
primaryOutputs
public FanoutOutputs primaryOutputs()
- Overrides:
primaryOutputs
in classActorProcessorImpl
-
running
public TransferPhase running()
-
pumpFinished
public void pumpFinished()
- Specified by:
pumpFinished
in interfacePump
- Overrides:
pumpFinished
in classActorProcessorImpl
-
postStop
public void postStop()
Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.- Specified by:
postStop
in interfaceActor
- Overrides:
postStop
in classActorProcessorImpl
-
afterFlush
public void afterFlush()
-
subTimeoutHandling
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> subTimeoutHandling()
- Specified by:
subTimeoutHandling
in classActorProcessorImpl
-
-