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 boolean
active()
void
active_$eq(boolean x$1)
int
cursor()
void
cursor_$eq(int x$1)
void
dispatch(T element)
org.reactivestreams.Subscriber<? super T>
subscriber()
long
totalDemand()
Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!void
totalDemand_$eq(long x$1)
-
-
-
Method Detail
-
active
boolean active()
-
active_$eq
void active_$eq(boolean x$1)
-
cursor
int cursor()
- Specified by:
cursor
in interfaceResizableMultiReaderRingBuffer.Cursor
-
cursor_$eq
void cursor_$eq(int x$1)
- Specified by:
cursor_$eq
in 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)
-
-