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 interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description FanoutProcessorImpl(Attributes attributes, ActorMaterializerSettings _settings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterFlush()
FanoutOutputs
primaryOutputs()
static Props
props(Attributes attributes, ActorMaterializerSettings actorMaterializerSettings)
void
pumpFinished()
TransferPhase
running()
-
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, postStop, primaryInputs, pumpFailed, receive, self, settings
-
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, ActorMaterializerSettings _settings)
-
-
Method Detail
-
props
public static Props props(Attributes attributes, ActorMaterializerSettings actorMaterializerSettings)
-
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
-
afterFlush
public void afterFlush()
-
-