Class TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>

java.lang.Object

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

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

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

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

All Implemented Interfaces:

Subscriber<T>

Enclosing class:

TestEnvironment

public static class TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>
extends TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>

Similar to TestEnvironment.ManualSubscriberWithSubscriptionSupport but does not accumulate values signalled via onNext, thus it can not be used to assert values signalled to this subscriber. Instead it may be used to quickly drain a given publisher.

Field Summary

Fields inherited from class TestEnvironment.ManualSubscriber

received

Fields inherited from class TestEnvironment.TestSubscriber

env, subscription

Constructor Summary

Constructors

Constructor	Description
BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
T	nextElement(long timeoutMillis, String errorMsg)
List<T>	nextElements(long elements, long timeoutMillis, String errorMsg)
void	onNext(T element)	Data notification sent by the Publisher in response to requests to Subscription.request(long).

Methods inherited from class TestEnvironment.ManualSubscriberWithSubscriptionSupport

onComplete, onError, onSubscribe

Methods inherited from class TestEnvironment.ManualSubscriber

expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectErrorWithMessage, expectErrorWithMessage, expectErrorWithMessage, expectErrorWithMessage, expectNext, expectNext, expectNone, expectNone, expectNone, expectNone, nextElement, nextElement, nextElement, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElements, nextElements, nextElements, request, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestNextElement, requestNextElement, requestNextElement, requestNextElement, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElements, requestNextElements, requestNextElements

Methods inherited from class TestEnvironment.TestSubscriber

cancel

Methods inherited from class Object

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

Constructor Details

BlackholeSubscriberWithSubscriptionSupport

public BlackholeSubscriberWithSubscriptionSupport(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.ManualSubscriberWithSubscriptionSupport<T>

Parameters:

element - the element signaled

nextElement

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

Overrides:

nextElement in class TestEnvironment.ManualSubscriber<T>

Throws:

InterruptedException

nextElements

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

Overrides:

nextElements in class TestEnvironment.ManualSubscriber<T>

Throws:

InterruptedException