akka.stream.stage

Class GraphStageLogic.StageActor

java.lang.Object

akka.stream.stage.GraphStageLogic.StageActor

Enclosing class:

GraphStageLogic

public static final class GraphStageLogic.StageActor
extends java.lang.Object

Minimal actor to work with other actors and watch them in a synchronous ways

Constructor Summary

Constructors

Constructor and Description
StageActor(ActorMaterializer materializer, scala.Function1<scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit>,AsyncCallback<scala.Tuple2<ActorRef,java.lang.Object>>> getAsyncCallback, scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> initialReceive)

Method Summary

Modifier and Type	Method and Description
void	become(scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> receive) Special become allowing to swap the behaviour of this StageActorRef.
void	internalReceive(scala.Tuple2<ActorRef,java.lang.Object> pack) INTERNAL API
ActorRef	ref() The ActorRef by which this StageActor can be contacted from the outside.
void	stop()
void	unwatch(ActorRef actorRef)
void	watch(ActorRef actorRef)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StageActor

public StageActor(ActorMaterializer materializer,
                  scala.Function1<scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit>,AsyncCallback<scala.Tuple2<ActorRef,java.lang.Object>>> getAsyncCallback,
                  scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> initialReceive)

Method Detail

ref

public ActorRef ref()

The ActorRef by which this StageActor can be contacted from the outside. This is a full-fledged ActorRef that supports watching and being watched as well as location transparent (remote) communication.

Returns:

(undocumented)

internalReceive

public void internalReceive(scala.Tuple2<ActorRef,java.lang.Object> pack)

INTERNAL API

become

public void become(scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> receive)

Special become allowing to swap the behaviour of this StageActorRef. Unbecome is not available.

Parameters:

receive - (undocumented)

stop

public void stop()

watch

public void watch(ActorRef actorRef)

unwatch

public void unwatch(ActorRef actorRef)