IdentityProcessorVerification.ManualSubscriberWithErrorCollection
, TestEnvironment.BlackholeSubscriberWithSubscriptionSupport
public static class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T> extends TestEnvironment.ManualSubscriber<T>
env
Constructor | Description |
---|---|
ManualSubscriberWithSubscriptionSupport(TestEnvironment env) |
Modifier and Type | Method | Description |
---|---|---|
void |
onComplete() |
|
void |
onError(java.lang.Throwable cause) |
|
void |
onNext(T element) |
|
void |
onSubscribe(org.reactivestreams.Subscription s) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectErrorWithMessage, expectErrorWithMessage, expectErrorWithMessage, expectNext, expectNext, expectNone, expectNone, expectNone, expectNone, nextElement, nextElement, nextElement, nextElement, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElements, nextElements, nextElements, nextElements, request, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestNextElement, requestNextElement, requestNextElement, requestNextElement, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElements, requestNextElements, requestNextElements
cancel
public ManualSubscriberWithSubscriptionSupport(TestEnvironment env)
public void onNext(T element)
onNext
in class TestEnvironment.ManualSubscriber<T>
public void onComplete()
onComplete
in class TestEnvironment.ManualSubscriber<T>
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in class TestEnvironment.TestSubscriber<T>
public void onError(java.lang.Throwable cause)
onError
in class TestEnvironment.TestSubscriber<T>