Package akka.stream.impl

Class ActorProcessorImpl

java.lang.Object

akka.stream.impl.ActorProcessorImpl

All Implemented Interfaces:

Actor, ActorLogging, Pump

Direct Known Subclasses:

FanoutProcessorImpl

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

Subclass may override activeReceive()

Nested Class Summary

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor	Description
ActorProcessorImpl(Attributes attributes, ActorMaterializerSettings settings)

Method Summary

Modifier and Type	Method	Description
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	activeReceive()
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 void	onError(java.lang.Throwable e)
void	postRestart(java.lang.Throwable reason)	User overridable callback: By default it calls preStart().
void	postStop()	User overridable callback.
protected Inputs	primaryInputs()
protected Outputs	primaryOutputs()
void	pumpFailed(java.lang.Throwable e)
void	pumpFinished()
ExposedPublisherReceive	receive()	Subclass may override activeReceive()
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

ActorProcessorImpl

public ActorProcessorImpl(Attributes attributes,
                          ActorMaterializerSettings settings)

Method Detail

activeReceive

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

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)

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

completedPhase

protected final TransferPhase completedPhase()

Specified by:

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

fail

protected void fail(java.lang.Throwable e)

onError

protected void onError(java.lang.Throwable e)

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.

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

primaryInputs

protected Inputs primaryInputs()

primaryOutputs

protected Outputs primaryOutputs()

pumpFailed

public void pumpFailed(java.lang.Throwable e)

Specified by:

pumpFailed in interface Pump

pumpFinished

public void pumpFinished()

Specified by:

pumpFinished in interface Pump

receive

public final ExposedPublisherReceive receive()

Subclass may override activeReceive()

Specified by:

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