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

INTERNAL API

Nested Class Summary

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
ActorProcessorImpl(ActorMaterializerSettings settings)

Method Summary

Modifier and Type	Method and Description
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	activeReceive()
protected TransferPhase	completedPhase()
ActorContext	context() 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

Methods inherited from interface akka.stream.impl.Pump

gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, waitForUpstreams

Constructor Detail

ActorProcessorImpl

public ActorProcessorImpl(ActorMaterializerSettings settings)

Method Detail

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

primaryInputs

protected Inputs primaryInputs()

primaryOutputs

protected Outputs primaryOutputs()

receive

public final ExposedPublisherReceive receive()

Subclass may override activeReceive()

Specified by:

receive in interface Actor

Returns:

(undocumented)

activeReceive

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

onError

protected void onError(java.lang.Throwable e)

fail

protected void fail(java.lang.Throwable e)

pumpFinished

public void pumpFinished()

Specified by:

pumpFinished in interface Pump

pumpFailed

public void pumpFailed(java.lang.Throwable e)

Specified by:

pumpFailed in interface Pump

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.