TestEnvironment.TestSubscriber (reactive-streams-tck 1.0.4 API)

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 Description

protected TestEnvironment env

Constructor Summary

Constructors
Constructor Description

TestSubscriber(TestEnvironment env)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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()
```