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

INTERNAL API

Method Summary

Modifier and Type	Method and Description
boolean	active()
int	cursor()
void	dispatch(T element)
org.reactivestreams.Subscriber<? super T>	subscriber()
long	totalDemand() Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!

Methods inherited from interface org.reactivestreams.Subscription

cancel, request

Method Detail

subscriber

org.reactivestreams.Subscriber<? super T> subscriber()

dispatch

void dispatch(T element)

active

boolean active()

totalDemand

long totalDemand()

Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!

cursor

int cursor()

Specified by:

cursor in interface ResizableMultiReaderRingBuffer.Cursor