Class TestEnvironment.ManualSubscriber<T>

java.lang.Object

org.reactivestreams.tck.TestEnvironment.TestSubscriber<T>

org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T>

All Implemented Interfaces:

Subscriber<T>

Direct Known Subclasses:

TestEnvironment.ManualSubscriberWithSubscriptionSupport

Enclosing class:

TestEnvironment

public static class TestEnvironment.ManualSubscriber<T>
extends TestEnvironment.TestSubscriber<T>

Subscriber implementation which can be steered by test code and asserted on.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) TestEnvironment.Receptacle<T>	received

Fields inherited from class TestEnvironment.TestSubscriber

env, subscription

Constructor Summary

Constructors

Constructor	Description
ManualSubscriber(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	expectCompletion()
void	expectCompletion(long timeoutMillis)
void	expectCompletion(long timeoutMillis, String errorMsg)
void	expectCompletion(String errorMsg)
<E extends Throwable> E	expectError(Class<E> expected)
<E extends Throwable> E	expectError(Class<E> expected, long timeoutMillis)
<E extends Throwable> E	expectError(Class<E> expected, long totalTimeoutMillis, long pollTimeoutMillis)
<E extends Throwable> E	expectError(Class<E> expected, long totalTimeoutMillis, long pollTimeoutMillis, String errorMsg)
<E extends Throwable> E	expectError(Class<E> expected, long timeoutMillis, String errorMsg)
<E extends Throwable> E	expectError(Class<E> expected, String errorMsg)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, String requiredMessagePart)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, String requiredMessagePart, long timeoutMillis)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, List<String> requiredMessagePartAlternatives)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, List<String> requiredMessagePartAlternatives, long timeoutMillis)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, List<String> requiredMessagePartAlternatives, long totalTimeoutMillis, long pollTimeoutMillis)
void	expectNext(T expected)
void	expectNext(T expected, long timeoutMillis)
void	expectNone()
void	expectNone(long withinMillis)
void	expectNone(long withinMillis, String errMsgPrefix)
void	expectNone(String errMsgPrefix)
T	nextElement()
T	nextElement(long timeoutMillis)
T	nextElement(long timeoutMillis, String errorMsg)
T	nextElement(String errorMsg)
Optional<T>	nextElementOrEndOfStream()
Optional<T>	nextElementOrEndOfStream(long timeoutMillis)
Optional<T>	nextElementOrEndOfStream(long timeoutMillis, String errorMsg)
List<T>	nextElements(long elements)
List<T>	nextElements(long elements, long timeoutMillis)
List<T>	nextElements(long elements, long timeoutMillis, String errorMsg)
List<T>	nextElements(long elements, String errorMsg)
void	onComplete()	Successful terminal state.
void	onNext(T element)	Data notification sent by the Publisher in response to requests to Subscription.request(long).
void	request(long elements)
void	requestEndOfStream()
void	requestEndOfStream(long timeoutMillis)
void	requestEndOfStream(long timeoutMillis, String errorMsg)
void	requestEndOfStream(String errorMsg)
T	requestNextElement()
T	requestNextElement(long timeoutMillis)
T	requestNextElement(long timeoutMillis, String errorMsg)
T	requestNextElement(String errorMsg)
Optional<T>	requestNextElementOrEndOfStream()
Optional<T>	requestNextElementOrEndOfStream(long timeoutMillis)
Optional<T>	requestNextElementOrEndOfStream(long timeoutMillis, String errorMsg)
Optional<T>	requestNextElementOrEndOfStream(String errorMsg)
List<T>	requestNextElements(long elements)
List<T>	requestNextElements(long elements, long timeoutMillis)
List<T>	requestNextElements(long elements, long timeoutMillis, String errorMsg)

Methods inherited from class TestEnvironment.TestSubscriber

cancel, onError, onSubscribe

Methods inherited from class Object

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

Field Details

received

TestEnvironment.Receptacle<T> received

Constructor Details

ManualSubscriber

public ManualSubscriber(TestEnvironment env)

Method Details

onNext

public void onNext(T element)

Description copied from interface: Subscriber

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Specified by:

onNext in interface Subscriber<T>

Overrides:

onNext in class TestEnvironment.TestSubscriber<T>

Parameters:

element - the element signaled

onComplete

public void onComplete()

Description copied from interface: Subscriber

Successful terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Specified by:

onComplete in interface Subscriber<T>

Overrides:

onComplete in class TestEnvironment.TestSubscriber<T>

request

public void request(long elements)

requestNextElement

public T requestNextElement()
                     throws InterruptedException

Throws:

InterruptedException

requestNextElement

public T requestNextElement(long timeoutMillis)
                     throws InterruptedException

Throws:

InterruptedException

requestNextElement

public T requestNextElement(String errorMsg)
                     throws InterruptedException

Throws:

InterruptedException

requestNextElement

public T requestNextElement(long timeoutMillis,
 String errorMsg)
                     throws InterruptedException

Throws:

InterruptedException

requestNextElementOrEndOfStream

public Optional<T> requestNextElementOrEndOfStream()
                                            throws InterruptedException

Throws:

InterruptedException

requestNextElementOrEndOfStream

public Optional<T> requestNextElementOrEndOfStream(String errorMsg)
                                            throws InterruptedException

Throws:

InterruptedException

requestNextElementOrEndOfStream

public Optional<T> requestNextElementOrEndOfStream(long timeoutMillis)
                                            throws InterruptedException

Throws:

InterruptedException

requestNextElementOrEndOfStream

public Optional<T> requestNextElementOrEndOfStream(long timeoutMillis,
 String errorMsg)
                                            throws InterruptedException

Throws:

InterruptedException

requestEndOfStream

public void requestEndOfStream()
                        throws InterruptedException

Throws:

InterruptedException

requestEndOfStream

public void requestEndOfStream(long timeoutMillis)
                        throws InterruptedException

Throws:

InterruptedException

requestEndOfStream

public void requestEndOfStream(String errorMsg)
                        throws InterruptedException

Throws:

InterruptedException

requestEndOfStream

public void requestEndOfStream(long timeoutMillis,
 String errorMsg)
                        throws InterruptedException

Throws:

InterruptedException

requestNextElements

public List<T> requestNextElements(long elements)
                            throws InterruptedException

Throws:

InterruptedException

requestNextElements

public List<T> requestNextElements(long elements,
 long timeoutMillis)
                            throws InterruptedException

Throws:

InterruptedException

requestNextElements

public List<T> requestNextElements(long elements,
 long timeoutMillis,
 String errorMsg)
                            throws InterruptedException

Throws:

InterruptedException

nextElement

public T nextElement()
              throws InterruptedException

Throws:

InterruptedException

nextElement

public T nextElement(long timeoutMillis)
              throws InterruptedException

Throws:

InterruptedException

nextElement

public T nextElement(String errorMsg)
              throws InterruptedException

Throws:

InterruptedException

nextElement

public T nextElement(long timeoutMillis,
 String errorMsg)
              throws InterruptedException

Throws:

InterruptedException

nextElementOrEndOfStream

public Optional<T> nextElementOrEndOfStream()
                                     throws InterruptedException

Throws:

InterruptedException

nextElementOrEndOfStream

public Optional<T> nextElementOrEndOfStream(long timeoutMillis)
                                     throws InterruptedException

Throws:

InterruptedException

nextElementOrEndOfStream

public Optional<T> nextElementOrEndOfStream(long timeoutMillis,
 String errorMsg)
                                     throws InterruptedException

Throws:

InterruptedException

nextElements

public List<T> nextElements(long elements)
                     throws InterruptedException

Throws:

InterruptedException

nextElements

public List<T> nextElements(long elements,
 String errorMsg)
                     throws InterruptedException

Throws:

InterruptedException

nextElements

public List<T> nextElements(long elements,
 long timeoutMillis)
                     throws InterruptedException

Throws:

InterruptedException

nextElements

public List<T> nextElements(long elements,
 long timeoutMillis,
 String errorMsg)
                     throws InterruptedException

Throws:

InterruptedException

expectNext

public void expectNext(T expected)
                throws InterruptedException

Throws:

InterruptedException

expectNext

public void expectNext(T expected,
 long timeoutMillis)
                throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion()
                      throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion(long timeoutMillis)
                      throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion(String errorMsg)
                      throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion(long timeoutMillis,
 String errorMsg)
                      throws InterruptedException

Throws:

InterruptedException

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 String requiredMessagePart)
                                                  throws Exception

Throws:

Exception

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 List<String> requiredMessagePartAlternatives)
                                                  throws Exception

Throws:

Exception

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 String requiredMessagePart,
 long timeoutMillis)
                                                  throws Exception

Throws:

Exception

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 List<String> requiredMessagePartAlternatives,
 long timeoutMillis)
                                                  throws Exception

Throws:

Exception

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 List<String> requiredMessagePartAlternatives,
 long totalTimeoutMillis,
 long pollTimeoutMillis)
                                                  throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected)
                                    throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 long timeoutMillis)
                                    throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 String errorMsg)
                                    throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 long timeoutMillis,
 String errorMsg)
                                    throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 long totalTimeoutMillis,
 long pollTimeoutMillis)
                                    throws Exception

Throws:

Exception

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 long totalTimeoutMillis,
 long pollTimeoutMillis,
 String errorMsg)
                                    throws Exception

Throws:

Exception

expectNone

public void expectNone()
                throws InterruptedException

Throws:

InterruptedException

expectNone

public void expectNone(String errMsgPrefix)
                throws InterruptedException

Throws:

InterruptedException

expectNone

public void expectNone(long withinMillis)
                throws InterruptedException

Throws:

InterruptedException

expectNone

public void expectNone(long withinMillis,
 String errMsgPrefix)
                throws InterruptedException

Throws:

InterruptedException