Package akka.stream.impl
Interface SubscriptionWithCursor<T>
-
- All Superinterfaces:
ResizableMultiReaderRingBuffer.Cursor,org.reactivestreams.Subscription
- All Known Implementing Classes:
ActorSubscriptionWithCursor
public interface SubscriptionWithCursor<T> extends org.reactivestreams.Subscription, ResizableMultiReaderRingBuffer.Cursor
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanactive()voidactive_$eq(boolean x$1)intcursor()voidcursor_$eq(int x$1)voiddispatch(T element)org.reactivestreams.Subscriber<? super T>subscriber()longtotalDemand()Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!voidtotalDemand_$eq(long x$1)
-
-
-
Method Detail
-
active
boolean active()
-
active_$eq
void active_$eq(boolean x$1)
-
cursor
int cursor()
- Specified by:
cursorin interfaceResizableMultiReaderRingBuffer.Cursor
-
cursor_$eq
void cursor_$eq(int x$1)
- Specified by:
cursor_$eqin interfaceResizableMultiReaderRingBuffer.Cursor
-
dispatch
void dispatch(T element)
-
subscriber
org.reactivestreams.Subscriber<? super T> subscriber()
-
totalDemand
long totalDemand()
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!
-
totalDemand_$eq
void totalDemand_$eq(long x$1)
-
-