Package org.reactivestreams.tck

Class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>

java.lang.Object

org.reactivestreams.tck.TestEnvironment.TestSubscriber<T>

org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T>

org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>

org.reactivestreams.tck.IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>

All Implemented Interfaces:

org.reactivestreams.Subscriber<A>

Enclosing class:

IdentityProcessorVerification<T>

public class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>
extends TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>

Field Summary

Fields inherited from class org.reactivestreams.tck.TestEnvironment.TestSubscriber

env

Constructor Summary

Constructors

Constructor	Description
ManualSubscriberWithErrorCollection(TestEnvironment env)

Method Summary

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)

Methods inherited from class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onComplete, onNext, 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, nextElement, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElements, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ManualSubscriberWithErrorCollection

public ManualSubscriberWithErrorCollection(TestEnvironment env)

Method Detail

onError

public void onError(java.lang.Throwable cause)

Specified by:

onError in interface org.reactivestreams.Subscriber<A>

Overrides:

onError in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>

expectError

public void expectError(java.lang.Throwable cause)
                 throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

expectError

public void expectError(java.lang.Throwable cause,
                        long timeoutMillis)
                 throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException