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:
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<java.lang.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
All Methods Instance Methods Concrete Methods 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)
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
-
-
-
-
Field Detail
-
error
TestEnvironment.Promise<java.lang.Throwable> error
-
-
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 interfaceSubscriber<A>
- Overrides:
onError
in classTestEnvironment.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
-
-