Package akka.stream.impl

Class FanOut

java.lang.Object

akka.stream.impl.FanOut

All Implemented Interfaces:

Actor, ActorLogging, Pump

Direct Known Subclasses:

Unzip

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

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FanOut.ExposedPublishers
static class	FanOut.ExposedPublishers$
static class	FanOut.FanoutOutputs
static class	FanOut.OutputBunch
static class	FanOut.SubstreamCancel
static class	FanOut.SubstreamCancel$
static class	FanOut.SubstreamRequestMore
static class	FanOut.SubstreamRequestMore$
static class	FanOut.SubstreamSubscribePending
static class	FanOut.SubstreamSubscribePending$
static class	FanOut.SubstreamSubscription

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor	Description
FanOut(ActorMaterializerSettings settings, int outputCount)

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)
protected TransferPhase	completedPhase()
ActorContext	context()	Scala API: Stores the context for this actor, including self, and sender.
protected void	fail(java.lang.Throwable e)
protected FanOut.OutputBunch	outputBunch()
int	outputCount()
void	postRestart(java.lang.Throwable reason)	User overridable callback: By default it calls preStart().
void	postStop()	User overridable callback.
protected Inputs	primaryInputs()
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

FanOut

public FanOut(ActorMaterializerSettings settings,
              int outputCount)

Method Detail

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

outputCount

public int outputCount()

outputBunch

protected FanOut.OutputBunch outputBunch()

primaryInputs

protected Inputs primaryInputs()

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)