public static class TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T> extends TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
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.env
Constructor and Description |
---|
BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env) |
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)
Data notification sent by the
Publisher in response to requests to Subscription.request(long) . |
onComplete, onError, onSubscribe
expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, 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, requestNextElements, requestNextElements, requestNextElements
cancel
public BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env)
public void onNext(T element)
Subscriber
Publisher
in response to requests to Subscription.request(long)
.onNext
in interface Subscriber<T>
onNext
in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
element
- the element signaledpublic T nextElement(long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
nextElement
in class TestEnvironment.ManualSubscriber<T>
java.lang.InterruptedException
public java.util.List<T> nextElements(long elements, long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
nextElements
in class TestEnvironment.ManualSubscriber<T>
java.lang.InterruptedException