Subscriber (reactive-streams 1.0.3 API)

Type Parameters:

T - the type of element signaled.

All Known Subinterfaces:

Processor<T,R>
```
public interface Subscriber<T>
```
Will receive call to onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).
No further notifications will be received until Subscription.request(long) is called.
After signaling demand:
- One or more invocations of onNext(Object) up to the maximum number defined by Subscription.request(long)
- Single invocation of onError(Throwable) or onComplete() which signals a terminal state after which no further events will be sent.
Demand can be signaled via Subscription.request(long) whenever the Subscriber instance is capable of handling more.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Successful terminal state.
`void`	`onError(java.lang.Throwable t)`	Failed terminal state.
`void`	`onNext(T t)`	Data notification sent by the `Publisher` in response to requests to `Subscription.request(long)`.
`void`	`onSubscribe(Subscription s)`	Invoked after calling `Publisher.subscribe(Subscriber)`.

- Method Detail
  - onSubscribe
```
void onSubscribe(Subscription s)
```
    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).
    
    Parameters:
    
    s - Subscription that allows requesting data via Subscription.request(long)
  - onNext
```
void onNext(T t)
```
    Data notification sent by the Publisher in response to requests to Subscription.request(long).
    
    Parameters:
    
    t - the element signaled
  - onError
```
void onError(java.lang.Throwable t)
```
    Failed terminal state.
    No further events will be sent even if Subscription.request(long) is invoked again.
    
    Parameters:
    
    t - the throwable signaled
  - onComplete
```
void onComplete()
```
    Successful terminal state.
    No further events will be sent even if Subscription.request(long) is invoked again.