Package akka.stream.impl

Class FanIn

java.lang.Object

akka.stream.impl.FanIn

All Implemented Interfaces:

Actor, ActorLogging, Pump

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

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
FanIn(ActorMaterializerSettings settings, int inputCount)

Method Summary

Modifier and Type	Method	Description
protected void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)	The 'self' field holds the ActorRef for this actor.
protected void	akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
static int	Cancelled()
static int	Completed()
protected TransferPhase	completedPhase()
ActorContext	context()	Scala API: Stores the context for this actor, including self, and sender.
static int	Depleted()
protected void	fail(java.lang.Throwable e)
protected FanIn.InputBunch	inputBunch()
int	inputCount()
static int	Marked()
static int	Pending()
void	postRestart(java.lang.Throwable reason)	User overridable callback: By default it calls preStart().
void	postStop()	User overridable callback.
protected Outputs	primaryOutputs()
void	pumpFailed(java.lang.Throwable e)
void	pumpFinished()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()	Scala API: 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.
ActorMaterializerSettings	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

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

completedPhase

protected final TransferPhase completedPhase()

Specified by:

completedPhase in interface Pump

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

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

Specified by:

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

context

public ActorContext context()

Description copied from interface: Actor

Scala API: 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 AbstractActor.ActorContext, 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)

akka$actor$Actor$_setter_$context_$eq

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

Specified by:

akka$actor$Actor$_setter_$context_$eq in interface Actor

akka$actor$Actor$_setter_$self_$eq

protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

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:

akka$actor$Actor$_setter_$self_$eq in interface Actor

Parameters:

x$1 - (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

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

Specified by:

receive in interface Actor

Returns:

(undocumented)