Class StageActor

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

Inheritance
object
StageActor
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public sealed class StageActor

Constructors

| Edit this page View Source

StageActor(ActorMaterializer, Func<Receive, Action<(IActorRef, object)>>, Receive, string)

Declaration
public StageActor(ActorMaterializer materializer, Func<StageActorRef.Receive, Action<(IActorRef, object)>> getAsyncCallback, StageActorRef.Receive initialReceive, string name = null)
Parameters
Type Name Description
ActorMaterializer materializer
Func<StageActorRef.Receive, Action<(IActorRef, object)>> getAsyncCallback
StageActorRef.Receive initialReceive
string name

Properties

| Edit this page View Source

Ref

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

Declaration
public IActorRef Ref { get; }
Property Value
Type Description
IActorRef

Methods

| Edit this page View Source

Become(Receive)

Special Become allowing to swap the behaviour of this StageActor. Unbecome is not available.

Declaration
public void Become(StageActorRef.Receive receive)
Parameters
Type Name Description
StageActorRef.Receive receive
| Edit this page View Source

Stop()

Stops current StageActor.

Declaration
public void Stop()
| Edit this page View Source

Unwatch(IActorRef)

Makes current StageActor stop watching previously Watch(IActorRef)ed actorRef. If actorRef was not watched over, this method has no result.

Declaration
public void Unwatch(IActorRef actorRef)
Parameters
Type Name Description
IActorRef actorRef
| Edit this page View Source

Watch(IActorRef)

Makes current StageActor watch over given actorRef. It will be notified when an underlying actor is Terminated.

Declaration
public void Watch(IActorRef actorRef)
Parameters
Type Name Description
IActorRef actorRef

Extension Methods