public class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A> extends TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>
env
Constructor and Description |
---|
ManualSubscriberWithErrorCollection(TestEnvironment env) |
Modifier and Type | Method and Description |
---|---|
void |
expectError(java.lang.Throwable cause) |
void |
expectError(java.lang.Throwable cause,
long timeoutMillis) |
void |
onError(java.lang.Throwable cause)
Failed terminal state.
|
onComplete, onNext, onSubscribe
expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, 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, requestNextElements, requestNextElements, requestNextElements
cancel
public ManualSubscriberWithErrorCollection(TestEnvironment env)
public void onError(java.lang.Throwable cause)
Subscriber
No further events will be sent even if Subscription.request(long)
is invoked again.
onError
in interface Subscriber<A>
onError
in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>
cause
- the throwable signaledpublic 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