 | ActorPublisherT Properties |
The ActorPublisherT generic type exposes the following members.
Properties| Name | Description | |
|---|---|---|
 | IsActive |
The state when the publisher is active, i.e. before the subscriber is attached
and when an subscriber is attached. It is allowed to
call OnComplete and OnError(Exception) in this state. It is
allowed to call OnNext(T) in this state when TotalDemand
is greater than zero.
|
| IsCanceled |
The state after the stream subscriber has canceled the subscription.
It is allowed to call OnNext(T), OnError(Exception), and OnComplete in
this state, but the calls will not perform anything.
|
| IsCompleted |
The terminal state after calling OnComplete. It is not allowed to
OnNext(T), OnError(Exception), and OnComplete in this state.
|
| IsErrorEmitted |
The terminal state after calling OnError(Exception). It is not allowed to
call OnNext(T), OnError(Exception), and OnComplete in this state.
|
 | Self |
Gets the self ActorRef
(Inherited from ActorBase.) |
| Sender |
Gets the sending ActorRef of the current message
(Inherited from ActorBase.) |
| SubscriptionTimeout |
Subscription timeout after which this actor will become Canceled and reject any incoming "late" subscriber.
The actor will receive an SubscriptionTimeoutExceeded message upon which it
MUST react by performing all necessary cleanup and stopping itself.
Use this feature in order to avoid leaking actors when you suspect that this Publisher may never get subscribed to by some Subscriber.
|
| TotalDemand |
Total number of requested elements from the stream subscriber.
This actor automatically keeps tracks of this amount based on
incoming request messages and outgoing OnNext(T).
|
See Also