Package akka.stream.impl
Class Unzip
- java.lang.Object
-
- akka.stream.impl.FanOut
-
- akka.stream.impl.Unzip
-
- All Implemented Interfaces:
Actor
,ActorLogging
,Pump
public class Unzip extends FanOut
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.impl.FanOut
FanOut.ExposedPublishers, FanOut.ExposedPublishers$, FanOut.FanoutOutputs, FanOut.OutputBunch, FanOut.SubstreamCancel, FanOut.SubstreamCancel$, FanOut.SubstreamRequestMore, FanOut.SubstreamRequestMore$, FanOut.SubstreamSubscribePending, FanOut.SubstreamSubscribePending$, FanOut.SubstreamSubscription
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description Unzip(Attributes attributes)
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Props
props(Attributes attributes)
-
Methods inherited from class akka.stream.impl.FanOut
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$stream$impl$Pump$_setter_$completedPhase_$eq, completedPhase, context, fail, outputBunch, outputCount, postRestart, postStop, primaryInputs, pumpFailed, pumpFinished, 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
-
Unzip
public Unzip(Attributes attributes)
-
-
Method Detail
-
props
public static Props props(Attributes attributes)
-
-