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:

org.reactivestreams.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.TestSubscriber

env

Constructor Summary

Constructors

Constructor	Description
ManualSubscriberWithSubscriptionSupport(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(java.lang.Throwable cause)
void	onNext(T element)
void	onSubscribe(org.reactivestreams.Subscription s)

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)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

Overrides:

onNext in class TestEnvironment.ManualSubscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

Overrides:

onComplete in class TestEnvironment.ManualSubscriber<T>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

Overrides:

onSubscribe in class TestEnvironment.TestSubscriber<T>

onError

public void onError(java.lang.Throwable cause)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

Overrides:

onError in class TestEnvironment.TestSubscriber<T>