GraphStageLogic.StageActor

java.lang.Object

org.apache.pekko.stream.stage.GraphStageLogic.StageActor

Enclosing class:: GraphStageLogic

public static final class GraphStageLogic.StageActor extends Object

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

Not for user instantiation, use GraphStageLogic.getStageActor.

Method Summary

Modifier and Type

Method

Description

void

become(scala.Function1<scala.Tuple2<ActorRef,Object>,scala.runtime.BoxedUnit> receive)

Special become 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)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- become
  
  public void become(scala.Function1<scala.Tuple2<ActorRef,Object>,scala.runtime.BoxedUnit> receive)
  
  Special become 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)