public class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A> extends TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>
env
Constructor | Description |
---|---|
ManualSubscriberWithErrorCollection(TestEnvironment env) |
Modifier and Type | Method | Description |
---|---|---|
void |
expectError(java.lang.Throwable cause) |
|
void |
expectError(java.lang.Throwable cause,
long timeoutMillis) |
|
void |
onError(java.lang.Throwable cause) |
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
onComplete, onNext, onSubscribe
cancel
public ManualSubscriberWithErrorCollection(TestEnvironment env)
public void onError(java.lang.Throwable cause)
onError
in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>
public void expectError(java.lang.Throwable cause) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectError(java.lang.Throwable cause, long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException