Package org.reactivestreams.tck

Class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>

java.lang.Object

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

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

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

Modifier and Type	Field	Description
(package private) TestEnvironment.Promise<Throwable>	error

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

received

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

env, subscription

Constructor Summary

Constructors

Constructor	Description
ManualSubscriberWithErrorCollection(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	expectError(Throwable cause)
void	expectError(Throwable cause, long timeoutMillis)
void	onError(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, 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

Field Details

error

TestEnvironment.Promise<Throwable> error

Constructor Details

ManualSubscriberWithErrorCollection

public ManualSubscriberWithErrorCollection(TestEnvironment env)

Method Details

onError

public void onError(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(Throwable cause)
                 throws InterruptedException

Throws:

InterruptedException

expectError

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

Throws:

InterruptedException