Package io.servicetalk.concurrent.api

Class TestSubscription

java.lang.Object

io.servicetalk.concurrent.api.TestCancellable

io.servicetalk.concurrent.api.TestSubscription

All Implemented Interfaces:

Cancellable, PublisherSource.Subscription

public final class TestSubscription
extends TestCancellable
implements PublisherSource.Subscription

A PublisherSource.Subscription that tracks requests and cancellation.

Field Summary

Fields inherited from interface io.servicetalk.concurrent.Cancellable

IGNORE_CANCEL

Constructor Summary

Constructors

Constructor	Description
TestSubscription()

Method Summary

Modifier and Type	Method	Description
void	awaitRequestN(long amount)	Wait until the PublisherSource.Subscription.request(long) amount exceeds amount.
void	awaitRequestNUninterruptibly(long amount)	Wait until the PublisherSource.Subscription.request(long) amount exceeds amount without being interrupted.
void	request(long n)	Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.
long	requested()	Returns the cumulative total of n from request(long)s.
boolean	requestedEquals(long value)	Test if the cumulative value of request(long) matches value.
java.lang.String	toString()

Methods inherited from class io.servicetalk.concurrent.api.TestCancellable

awaitCancelled, awaitCancelledUninterruptibly, cancel, isCancelled

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.concurrent.Cancellable

cancel

Constructor Detail

TestSubscription

public TestSubscription()

Method Detail

request

public void request(long n)

Description copied from interface: PublisherSource.Subscription

Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

request in interface PublisherSource.Subscription

Parameters:

n - Number of items to request.

requested

public long requested()

Returns the cumulative total of n from request(long)s.

Returns:

the cumulative total of n from request(long)s.

requestedEquals

public boolean requestedEquals(long value)

Test if the cumulative value of request(long) matches value. This method will take into account invalid values (e.g. 0) which may otherwise be challenging to validate with requested().

Parameters:

value - The invalid value to check.

Returns:

true if the cumulative value of request(long) matches value.

awaitRequestN

public void awaitRequestN(long amount)
                   throws java.lang.InterruptedException

Wait until the PublisherSource.Subscription.request(long) amount exceeds amount.

Parameters:

amount - the amount to wait for.

Throws:

java.lang.InterruptedException - If this thread is interrupted while waiting.

awaitRequestNUninterruptibly

public void awaitRequestNUninterruptibly(long amount)

Wait until the PublisherSource.Subscription.request(long) amount exceeds amount without being interrupted. This method catches an InterruptedException and discards it silently.

Parameters:

amount - the amount to wait for.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object