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
All Methods Static Methods Instance Methods Concrete Methods 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 callspreStart()
.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 interfacePump
-
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 interfacePump
-
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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
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
-
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 interfaceActor
-
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 interfaceActor
- 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 interfacePump
-
pumpFailed
public void pumpFailed(java.lang.Throwable e)
- Specified by:
pumpFailed
in interfacePump
-
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.
-
postRestart
public void postRestart(java.lang.Throwable reason)
Description copied from interface:Actor
User overridable callback: By default it callspreStart()
.- Specified by:
postRestart
in interfaceActor
- 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.
-
-