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:

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 and Description
ManualSubscriberWithErrorCollection(TestEnvironment env)

Method Summary

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.

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, 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

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)

Description copied from interface: Subscriber

Failed terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Specified by:

onError in interface Subscriber<A>

Overrides:

onError in class TestEnvironment.ManualSubscriberWithSubscriptionSupport<A>

Parameters:

cause - the throwable signaled

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