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

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 the Publisher in response to requests to Subscription.request(long).
void	onSubscribe(Subscription s)	Invoked after calling Publisher.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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ManualSubscriberWithSubscriptionSupport

public ManualSubscriberWithSubscriptionSupport(TestEnvironment env)

Method Detail

onNext

public void onNext(T element)

Description copied from interface: Subscriber

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Specified by:

onNext in interface Subscriber<T>

Overrides:

onNext in class TestEnvironment.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 interface Subscriber<T>

Overrides:

onComplete in class TestEnvironment.ManualSubscriber<T>

onSubscribe

public void onSubscribe(Subscription s)

Description copied from interface: Subscriber

Invoked after calling Publisher.subscribe(Subscriber).

No data will start flowing until Subscription.request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription.request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription.request(long).

Specified by:

onSubscribe in interface Subscriber<T>

Overrides:

onSubscribe in class TestEnvironment.TestSubscriber<T>

Parameters:

s - the Subscription that allows requesting data via Subscription.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 interface Subscriber<T>

Overrides:

onError in class TestEnvironment.TestSubscriber<T>

Parameters:

cause - the throwable signaled