Class ActorSubscriber

Extend this actor to make it a stream subscriber with full control of stream back pressure. It will receive OnNext, OnComplete and OnError messages from the stream. It can also receive other, non-stream messages, in the same way as any actor.

Attach the actor as a Reactive.Streams.ISubscriber<T> to the stream with Create<T>(IActorRef)

Subclass must define the RequestStrategy to control stream back pressure. After each incoming message the ActorSubscriber will automatically invoke the RequestDemand(Int32) and propagate the returned demand to the stream. The provided WatermarkRequestStrategy is a good strategy if the actor performs work itself. The provided MaxInFlightRequestStrategy is useful if messages are queued internally or delegated to other actors. You can also implement a custom IRequestStrategy or call Request(Int64) manually together with ZeroRequestStrategy or some other strategy. In that case you must also call Request(Int64) when the actor is started or when it is ready, otherwise it will not receive any elements.

Inheritance
Object
ActorBase
ActorSubscriber
Implements
Inherited Members
Namespace: Akka.Streams.Actors
Assembly: Akka.Streams.dll
Syntax
public abstract class ActorSubscriber : ActorBase, IInternalActor

Properties

| Improve this Doc View Source

IsCanceled

TBD

Declaration
public bool IsCanceled { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

RemainingRequested

The number of stream elements that have already been requested from upstream but not yet received.

Declaration
protected int RemainingRequested { get; }
Property Value
Type Description
Int32
| Improve this Doc View Source

RequestStrategy

TBD

Declaration
public abstract IRequestStrategy RequestStrategy { get; }
Property Value
Type Description
IRequestStrategy

Methods

| Improve this Doc View Source

AroundPostRestart(Exception, Object)

TBD

Declaration
public override void AroundPostRestart(Exception cause, object message)
Parameters
Type Name Description
Exception cause

TBD
Object message

TBD
Overrides
| Improve this Doc View Source

AroundPostStop()

TBD

Declaration
public override void AroundPostStop()
Overrides
| Improve this Doc View Source

AroundPreRestart(Exception, Object)

TBD

Declaration
public override void AroundPreRestart(Exception cause, object message)
Parameters
Type Name Description
Exception cause

TBD
Object message

TBD
Overrides
| Improve this Doc View Source

AroundPreStart()

TBD

Declaration
public override void AroundPreStart()
Overrides
| Improve this Doc View Source

AroundReceive(Receive, Object)

TBD

Declaration
protected override bool AroundReceive(Receive receive, object message)
Parameters
Type Name Description
Receive receive

TBD
Object message

TBD
Returns
Type Description
Boolean

TBD
Overrides
| Improve this Doc View Source

Cancel()

Cancel upstream subscription. No more elements will be delivered after cancel.

The ActorSubscriber will be stopped immediately after signaling cancellation. In case the upstream subscription has not yet arrived the Actor will stay alive until a subscription arrives, cancel it and then stop itself.

Declaration
protected void Cancel()
| Improve this Doc View Source

Create<T>(IActorRef)

Attach a ActorSubscriber actor as a Reactive.Streams.ISubscriber<T> to a Reactive.Streams.IPublisher<T> or IFlow<TOut, TMat>

Declaration
public static ISubscriber<T> Create<T>(IActorRef ref)
Parameters
Type Name Description
IActorRef ref

TBD
Returns
Type Description
Reactive.Streams.ISubscriber<T>

TBD
Type Parameters
Name Description
T

TBD
| Improve this Doc View Source

Request(Int64)

Request a number of elements from upstream.

Declaration
protected void Request(long n)
Parameters
Type Name Description
Int64 n

TBD

Implements

Extension Methods