Class AsyncIterablePublisher.SubscriptionImpl

java.lang.Object

org.reactivestreams.example.unicast.AsyncIterablePublisher.SubscriptionImpl

All Implemented Interfaces:

Runnable, Subscription

Enclosing class:

AsyncIterablePublisher<T>

final class AsyncIterablePublisher.SubscriptionImpl
extends Object
implements Subscription, Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	cancelled
private long	demand
private final ConcurrentLinkedQueue<AsyncIterablePublisher.Signal>	inboundSignals
private Iterator<T>	iterator
private final AtomicBoolean	on
(package private) final Subscriber<? super T>	subscriber

Constructor Summary

Constructors

Constructor	Description
SubscriptionImpl(Subscriber<? super T> subscriber)

Method Summary

Modifier and Type	Method	Description
void	cancel()	Request the Publisher to stop sending data and clean up resources.
private void	doCancel()
private void	doRequest(long n)
private void	doSend()
private void	doSubscribe()
(package private) void	init()
void	request(long n)	No events will be sent by a Publisher until demand is signaled via this method.
final void	run()
private void	signal(AsyncIterablePublisher.Signal signal)
private void	terminateDueTo(Throwable t)
private final void	tryScheduleToExecute()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

subscriber

final Subscriber<? super T> subscriber

cancelled

private boolean cancelled

demand

private long demand

iterator

private Iterator<T> iterator

inboundSignals

private final ConcurrentLinkedQueue<AsyncIterablePublisher.Signal> inboundSignals

on

private final AtomicBoolean on

Constructor Details

SubscriptionImpl

SubscriptionImpl(Subscriber<? super T> subscriber)

Method Details

doRequest

private void doRequest(long n)

doCancel

private void doCancel()

doSubscribe

private void doSubscribe()

doSend

private void doSend()

terminateDueTo

private void terminateDueTo(Throwable t)

signal

private void signal(AsyncIterablePublisher.Signal signal)

run

public final void run()

Specified by:

run in interface Runnable

tryScheduleToExecute

private final void tryScheduleToExecute()

request

public void request(long n)

Description copied from interface: Subscription

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber.onError(Throwable) or Subscriber.onComplete().

Specified by:

request in interface Subscription

Parameters:

n - the strictly positive number of elements to requests to the upstream Publisher

cancel

public void cancel()

Description copied from interface: Subscription

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Specified by:

cancel in interface Subscription

init

void init()