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 and Description
ActorSubscriptionWithCursor(ActorRef _impl, org.reactivestreams.Subscriber<? super T> _subscriber)

Method Summary

Modifier and Type	Method and Description
boolean	active()
int	cursor()
long	totalDemand() Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!

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

Methods inherited from interface org.reactivestreams.Subscription

cancel, request

Constructor Detail

ActorSubscriptionWithCursor

public ActorSubscriptionWithCursor(ActorRef _impl,
                                   org.reactivestreams.Subscriber<? super T> _subscriber)

Method Detail

active

public boolean active()

Specified by:

active in interface SubscriptionWithCursor<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 interface SubscriptionWithCursor<T>

cursor

public int cursor()

Specified by:

cursor in interface ResizableMultiReaderRingBuffer.Cursor

Specified by:

cursor in interface SubscriptionWithCursor<T>