Package 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 waysNot for user instantiation, use
GraphStageLogic.getStageActor(scala.Function1<scala.Tuple2<akka.actor.ActorRef, java.lang.Object>, scala.runtime.BoxedUnit>)
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
become(scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> receive)
Specialbecome
allowing to swap the behavior of this StageActorRef.ActorRef
ref()
The ActorRef by which this StageActor can be contacted from the outside.void
stop()
void
unwatch(ActorRef actorRef)
void
watch(ActorRef actorRef)
-
-
-
Method Detail
-
become
public void become(scala.Function1<scala.Tuple2<ActorRef,java.lang.Object>,scala.runtime.BoxedUnit> receive)
Specialbecome
allowing to swap the behavior of this StageActorRef. Unbecome is not available.
-
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.
-
stop
public void stop()
-
unwatch
public void unwatch(ActorRef actorRef)
-
watch
public void watch(ActorRef actorRef)
-
-