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
FieldsFields inherited from class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
received
Fields inherited from class org.reactivestreams.tck.TestEnvironment.TestSubscriber
env, subscription
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
expectError
(Throwable cause) void
expectError
(Throwable cause, long timeoutMillis) void
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 Details
-
error
TestEnvironment.Promise<Throwable> error
-
-
Constructor Details
-
ManualSubscriberWithErrorCollection
-
-
Method Details
-
onError
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
- Throws:
InterruptedException
-
expectError
- Throws:
InterruptedException
-