org.reactivestreams.tck

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:

org.reactivestreams.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 org.reactivestreams.tck.TestEnvironment.TestSubscriber

env

Constructor Summary

Constructors

Constructor and Description
BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env)

Method Summary

Modifier and Type	Method and Description
T	nextElement(long timeoutMillis, java.lang.String errorMsg)
java.util.List<T>	nextElements(long elements, long timeoutMillis, java.lang.String errorMsg)
void	onNext(T element)

Methods inherited from class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onComplete, onError, onSubscribe

Methods inherited from class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, 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 org.reactivestreams.tck.TestEnvironment.TestSubscriber

cancel

Methods inherited from class java.lang.Object

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

Constructor Detail

BlackholeSubscriberWithSubscriptionSupport

public BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env)

Method Detail

onNext

public void onNext(T element)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

Overrides:

onNext in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>

nextElement

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

Overrides:

nextElement in class TestEnvironment.ManualSubscriber<T>

Throws:

java.lang.InterruptedException

nextElements

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

Overrides:

nextElements in class TestEnvironment.ManualSubscriber<T>

Throws:

java.lang.InterruptedException