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 booleanactive()voidactive_$eq(boolean x$1)intcursor()voidcursor_$eq(int x$1)longtotalDemand()Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!voidtotalDemand_$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:
activein interfaceSubscriptionWithCursor<T>
-
active_$eq
public void active_$eq(boolean x$1)
- Specified by:
active_$eqin interfaceSubscriptionWithCursor<T>
-
cursor
public int cursor()
- Specified by:
cursorin interfaceResizableMultiReaderRingBuffer.Cursor- Specified by:
cursorin interfaceSubscriptionWithCursor<T>
-
cursor_$eq
public void cursor_$eq(int x$1)
- Specified by:
cursor_$eqin interfaceResizableMultiReaderRingBuffer.Cursor- Specified by:
cursor_$eqin interfaceSubscriptionWithCursor<T>
-
totalDemand
public long totalDemand()
Description copied from interface:SubscriptionWithCursorDo not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!- Specified by:
totalDemandin interfaceSubscriptionWithCursor<T>
-
totalDemand_$eq
public void totalDemand_$eq(long x$1)
- Specified by:
totalDemand_$eqin interfaceSubscriptionWithCursor<T>
-
-