public class ActorSubscriptionWithCursor<T> extends ActorSubscription<T> implements SubscriptionWithCursor<T>
Constructor and Description |
---|
ActorSubscriptionWithCursor(ActorRef _impl,
org.reactivestreams.Subscriber<? super T> _subscriber) |
Modifier and Type | Method and Description |
---|---|
boolean |
active() |
int |
cursor() |
long |
totalDemand()
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!
|
cancel, impl, request, subscriber
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dispatch, subscriber
public boolean active()
active
in interface SubscriptionWithCursor<T>
public long totalDemand()
SubscriptionWithCursor
totalDemand
in interface SubscriptionWithCursor<T>
public int cursor()
cursor
in interface ResizableMultiReaderRingBuffer.Cursor
cursor
in interface SubscriptionWithCursor<T>