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
-
-
Constructor Summary
Constructors Constructor 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)
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, java.lang.String name)
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, java.lang.String name, boolean poisonPillFallback)
-
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.void
internalReceive(scala.Tuple2<ActorRef,java.lang.Object> pack)
INTERNAL APIActorRef
ref()
The ActorRef by which this StageActor can be contacted from the outside.void
stop()
void
unwatch(ActorRef actorRef)
void
watch(ActorRef actorRef)
-
-
-
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, java.lang.String name, boolean poisonPillFallback)
-
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, java.lang.String name)
-
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
-
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.- Parameters:
receive
- (undocumented)
-
internalReceive
public void internalReceive(scala.Tuple2<ActorRef,java.lang.Object> pack)
INTERNAL API
-
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)
-
stop
public void stop()
-
unwatch
public void unwatch(ActorRef actorRef)
-
watch
public void watch(ActorRef actorRef)
-
-