PublisherSource.Subscriber

Type Parameters:

T - Type of items received by this Subscriber.

All Known Subinterfaces:

PublisherSource.Processor<T,R>

All Known Implementing Classes:

CancelImmediatelySubscriber, ConcurrentTerminalSubscriber, DemandCheckingSubscriber, LatestValueSubscriber, LoggingPublisherSubscriber, TestPublisherSubscriber

Enclosing interface:

PublisherSource<T>
```
public static interface PublisherSource.Subscriber<T>
```
A subscriber of result(s) produced by a PublisherSource.
This is a replica of the APIs provided by Reactive Streams and follows the Reactive Streams specifications. All implementations of this Subscriber adhere to the rules as specified for a Reactive Streams Subscriber in Section 2 of the specifications.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Callback to signal completion of the `PublisherSource` for this `Subscriber`.
`void`	`onError(java.lang.Throwable t)`	Callback to receive an `error` for this `Subscriber`.
`void`	`onNext(T t)`	Callback to receive a `data` element for this `Subscriber`.
`void`	`onSubscribe(PublisherSource.Subscription subscription)`	Callback to receive a `PublisherSource.Subscription` for this `Subscriber`.

- Method Detail
  - onSubscribe
```
void onSubscribe(PublisherSource.Subscription subscription)
```
    Callback to receive a PublisherSource.Subscription for this Subscriber.
    See Reactive Streams specifications for the rules about how and when this method will be invoked.
    
    Parameters:
    
    subscription - PublisherSource.Subscription for this Subscriber.
  - onNext
```
void onNext(@Nullable
            T t)
```
    Callback to receive a data element for this Subscriber.
    See Reactive Streams specifications for the rules about how and when this method will be invoked.
    
    Parameters:
    
    t - A data element.
  - onError
```
void onError(java.lang.Throwable t)
```
    Callback to receive an error for this Subscriber.
    See Reactive Streams specifications for the rules about how and when this method will be invoked.
    
    Parameters:
    
    t - error for this Subscriber.
  - onComplete
```
void onComplete()
```
    Callback to signal completion of the PublisherSource for this Subscriber.
    See Reactive Streams specifications for the rules about how and when this method will be invoked.