Package 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:
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.ManualSubscriber
received
Fields inherited from class org.reactivestreams.tck.TestEnvironment.TestSubscriber
env, subscription
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionnextElement
(long timeoutMillis, String errorMsg) nextElements
(long elements, long timeoutMillis, String errorMsg) void
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.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, 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 org.reactivestreams.tck.TestEnvironment.TestSubscriber
cancel
-
Constructor Details
-
BlackholeSubscriberWithSubscriptionSupport
-
-
Method Details
-
onNext
Description copied from interface:Subscriber
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.- Specified by:
onNext
in interfaceSubscriber<T>
- Overrides:
onNext
in classTestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
- Parameters:
element
- the element signaled
-
nextElement
- Overrides:
nextElement
in classTestEnvironment.ManualSubscriber<T>
- Throws:
InterruptedException
-
nextElements
public List<T> nextElements(long elements, long timeoutMillis, String errorMsg) throws InterruptedException - Overrides:
nextElements
in classTestEnvironment.ManualSubscriber<T>
- Throws:
InterruptedException
-