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 and Description
Unzip(ActorMaterializerSettings _settings)

Method Summary

Modifier and Type	Method and Description
protected static void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
static void	akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
static LoggingAdapter	akka$actor$ActorLogging$$_log()
protected static void	akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
static void	akka$stream$impl$Pump$$currentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1)
static scala.Function0<scala.runtime.BoxedUnit>	akka$stream$impl$Pump$$currentAction()
static void	akka$stream$impl$Pump$$transferState_$eq(TransferState x$1)
static TransferState	akka$stream$impl$Pump$$transferState()
protected static void	aroundPostRestart(java.lang.Throwable reason)
protected static void	aroundPostStop()
protected static void	aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void	aroundPreStart()
protected static void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static TransferPhase	completedPhase()
static ActorContext	context()
protected static void	fail(java.lang.Throwable e)
static void	gotUpstreamSubscription()
static void	initialPhase(int waitForUpstream, TransferPhase andThen)
static boolean	isPumpFinished()
static LoggingAdapter	log()
static void	nextPhase(TransferPhase phase)
protected static FanOut.OutputBunch	outputBunch()
static int	outputCount()
static void	postRestart(java.lang.Throwable reason)
static void	postStop()
static void	preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
static void	preStart()
protected static Inputs	primaryInputs()
static Props	props(ActorMaterializerSettings settings)
static void	pump()
static void	pumpFailed(java.lang.Throwable e)
static void	pumpFinished()
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
static ActorRef	self()
static ActorRef	sender()
static ActorMaterializerSettings	settings()
static SupervisorStrategy	supervisorStrategy()
static void	unhandled(java.lang.Object message)
static void	waitForUpstreams(int waitForUpstream)

Methods inherited from class akka.stream.impl.FanOut

completedPhase, context, fail, outputBunch, outputCount, postRestart, postStop, primaryInputs, pumpFailed, pumpFinished, 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

Methods inherited from interface akka.stream.impl.Pump

gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, waitForUpstreams

Constructor Detail

Unzip

public Unzip(ActorMaterializerSettings _settings)

Method Detail

props

public static Props props(ActorMaterializerSettings settings)

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)

supervisorStrategy

public static SupervisorStrategy supervisorStrategy()

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)

log

public static LoggingAdapter log()

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()

settings

public static ActorMaterializerSettings settings()

outputCount

public static int outputCount()

outputBunch

protected static FanOut.OutputBunch outputBunch()

primaryInputs

protected static Inputs primaryInputs()

pumpFinished

public static void pumpFinished()

pumpFailed

public static void pumpFailed(java.lang.Throwable e)

fail

protected static void fail(java.lang.Throwable e)

postStop

public static void postStop()

postRestart

public static void postRestart(java.lang.Throwable reason)

receive

public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

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)

context

public static ActorContext context()

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)