Package org.reactivestreams.tck
Class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
- java.lang.Object
-
- org.reactivestreams.tck.TestEnvironment.TestSubscriber<T>
-
- org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T>
-
- org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
-
- All Implemented Interfaces:
Subscriber<T>
- Direct Known Subclasses:
IdentityProcessorVerification.ManualSubscriberWithErrorCollection
,TestEnvironment.BlackholeSubscriberWithSubscriptionSupport
- Enclosing class:
- TestEnvironment
public static class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T> extends TestEnvironment.ManualSubscriber<T>
-
-
Field Summary
-
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 ManualSubscriberWithSubscriptionSupport(TestEnvironment env)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
Successful terminal state.void
onError(java.lang.Throwable cause)
Failed terminal state.void
onNext(T element)
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.void
onSubscribe(Subscription s)
Invoked after callingPublisher.subscribe(Subscriber)
.-
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
-
-
-
-
Constructor Detail
-
ManualSubscriberWithSubscriptionSupport
public ManualSubscriberWithSubscriptionSupport(TestEnvironment env)
-
-
Method Detail
-
onNext
public void onNext(T element)
Description copied from interface:Subscriber
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.- Specified by:
onNext
in interfaceSubscriber<T>
- Overrides:
onNext
in classTestEnvironment.ManualSubscriber<T>
- Parameters:
element
- the element signaled
-
onComplete
public void onComplete()
Description copied from interface:Subscriber
Successful terminal state.No further events will be sent even if
Subscription.request(long)
is invoked again.- Specified by:
onComplete
in interfaceSubscriber<T>
- Overrides:
onComplete
in classTestEnvironment.ManualSubscriber<T>
-
onSubscribe
public void onSubscribe(Subscription s)
Description copied from interface:Subscriber
Invoked after callingPublisher.subscribe(Subscriber)
.No data will start flowing until
Subscription.request(long)
is invoked.It is the responsibility of this
Subscriber
instance to callSubscription.request(long)
whenever more data is wanted.The
Publisher
will send notifications only in response toSubscription.request(long)
.- Specified by:
onSubscribe
in interfaceSubscriber<T>
- Overrides:
onSubscribe
in classTestEnvironment.TestSubscriber<T>
- Parameters:
s
- theSubscription
that allows requesting data viaSubscription.request(long)
-
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<T>
- Overrides:
onError
in classTestEnvironment.TestSubscriber<T>
- Parameters:
cause
- the throwable signaled
-
-