akka.stream.impl

Class FanIn

java.lang.Object

akka.stream.impl.FanIn

All Implemented Interfaces:

Actor, ActorLogging, Pump

public abstract class FanIn
extends java.lang.Object
implements Actor, ActorLogging, Pump

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FanIn.InputBunch
static class	FanIn.OnComplete
static class	FanIn.OnComplete$
static class	FanIn.OnError
static class	FanIn.OnError$
static class	FanIn.OnNext
static class	FanIn.OnNext$
static class	FanIn.OnSubscribe
static class	FanIn.OnSubscribe$
static class	FanIn.SubInput<T>
static class	FanIn.SubInput$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
FanIn(ActorMaterializerSettings settings, int inputCount)

Method Summary

Modifier and Type	Method and Description
protected abstract static void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected abstract 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 abstract 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)
static int	Cancelled()
static int	Completed()
protected TransferPhase	completedPhase()
ActorContext	context() Stores the context for this actor, including self, and sender.
static int	Depleted()
protected void	fail(java.lang.Throwable e)
static void	gotUpstreamSubscription()
static void	initialPhase(int waitForUpstream, TransferPhase andThen)
protected FanIn.InputBunch	inputBunch()
int	inputCount()
static boolean	isPumpFinished()
static LoggingAdapter	log()
static int	Marked()
static void	nextPhase(TransferPhase phase)
static int	Pending()
void	postRestart(java.lang.Throwable reason) User overridable callback: By default it calls preStart().
void	postStop() User overridable callback.
static void	preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
static void	preStart()
protected Outputs	primaryOutputs()
static void	pump()
void	pumpFailed(java.lang.Throwable e)
void	pumpFinished()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive() This defines the initial actor behavior, it must return a partial function with the actor logic.
ActorRef	self() The 'self' field holds the ActorRef for this actor.
static ActorRef	sender()
ActorMaterializerSettings	settings()
static SupervisorStrategy	supervisorStrategy()
static void	unhandled(java.lang.Object message)
static void	waitForUpstreams(int waitForUpstream)

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

FanIn

public FanIn(ActorMaterializerSettings settings,
             int inputCount)

Method Detail

Marked

public static final int Marked()

Pending

public static final int Pending()

Depleted

public static final int Depleted()

Completed

public static final int Completed()

Cancelled

public static final int Cancelled()

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)

akka$actor$Actor$_setter_$context_$eq

protected abstract static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected abstract static void akka$actor$Actor$_setter_$self_$eq(ActorRef 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)

log

public static LoggingAdapter log()

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)

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

akka$stream$impl$Pump$_setter_$completedPhase_$eq

protected abstract static void akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)

completedPhase

protected final TransferPhase completedPhase()

Specified by:

completedPhase in interface Pump

context

public ActorContext context()

Description copied from interface: Actor

Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

ActorContext is the Scala API. getContext returns a UntypedActorContext, which is the Java API of the actor context.

Specified by:

context in interface Actor

Returns:

(undocumented)

self

public final ActorRef self()

Description copied from interface: Actor

The 'self' field holds the ActorRef for this actor.

Can be used to send messages to itself:

 self ! message
 

Specified by:

self in interface Actor

Returns:

(undocumented)

settings

public ActorMaterializerSettings settings()

inputCount

public int inputCount()

primaryOutputs

protected Outputs primaryOutputs()

inputBunch

protected FanIn.InputBunch inputBunch()

pumpFinished

public void pumpFinished()

Specified by:

pumpFinished in interface Pump

pumpFailed

public void pumpFailed(java.lang.Throwable e)

Specified by:

pumpFailed in interface Pump

fail

protected void fail(java.lang.Throwable e)

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 interface Actor

postRestart

public void postRestart(java.lang.Throwable reason)

Description copied from interface: Actor

User overridable callback: By default it calls preStart().

Specified by:

postRestart in interface Actor

Parameters:

reason - the Throwable that caused the restart to happen

Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.

receive

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

Description copied from interface: Actor

This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

Returns:

(undocumented)