Package akka.stream.impl
Class ActorSubscriptionWithCursor<T>
- java.lang.Object
-
- akka.stream.impl.ActorSubscription<T>
-
- akka.stream.impl.ActorSubscriptionWithCursor<T>
-
- All Implemented Interfaces:
ResizableMultiReaderRingBuffer.Cursor
,SubscriptionWithCursor<T>
,org.reactivestreams.Subscription
public class ActorSubscriptionWithCursor<T> extends ActorSubscription<T> implements SubscriptionWithCursor<T>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ActorSubscriptionWithCursor(ActorRef _impl, org.reactivestreams.Subscriber<? super T> _subscriber)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
active()
void
active_$eq(boolean x$1)
int
cursor()
void
cursor_$eq(int x$1)
long
totalDemand()
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!void
totalDemand_$eq(long x$1)
-
Methods inherited from class akka.stream.impl.ActorSubscription
cancel, impl, request, subscriber
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.stream.impl.SubscriptionWithCursor
dispatch, subscriber
-
-
-
-
Method Detail
-
active
public boolean active()
- Specified by:
active
in interfaceSubscriptionWithCursor<T>
-
active_$eq
public void active_$eq(boolean x$1)
- Specified by:
active_$eq
in interfaceSubscriptionWithCursor<T>
-
cursor
public int cursor()
- Specified by:
cursor
in interfaceResizableMultiReaderRingBuffer.Cursor
- Specified by:
cursor
in interfaceSubscriptionWithCursor<T>
-
cursor_$eq
public void cursor_$eq(int x$1)
- Specified by:
cursor_$eq
in interfaceResizableMultiReaderRingBuffer.Cursor
- Specified by:
cursor_$eq
in interfaceSubscriptionWithCursor<T>
-
totalDemand
public long totalDemand()
Description copied from interface:SubscriptionWithCursor
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!- Specified by:
totalDemand
in interfaceSubscriptionWithCursor<T>
-
totalDemand_$eq
public void totalDemand_$eq(long x$1)
- Specified by:
totalDemand_$eq
in interfaceSubscriptionWithCursor<T>
-
-