org.reactivestreams.tck

Class TestEnvironment.TestSubscriber<T>

java.lang.Object

org.reactivestreams.tck.TestEnvironment.TestSubscriber<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

TestEnvironment.ManualSubscriber

Enclosing class:

TestEnvironment

public static class TestEnvironment.TestSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected TestEnvironment	env

Constructor Summary

Constructors

Constructor and Description
TestSubscriber(TestEnvironment env)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

env

protected final TestEnvironment env

Constructor Detail

TestSubscriber

public TestSubscriber(TestEnvironment env)

Method Detail

onError

public void onError(java.lang.Throwable cause)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T element)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

cancel

public void cancel()