Flow.Subscriber (Java SE 9 & JDK 9 )

参数类型

T - 订阅的项目类型

All Known Subinterfaces:

Flow.Processor<T,R> ， HttpResponse.BodyProcessor<T>

Enclosing class:

Flow
```
public static interface Flow.Subscriber<T>
```
消息的接收者。对于每个Flow.Subscription ，该接口中的方法以严格的顺序调用。

方法摘要

所有方法接口方法抽象方法
Modifier and Type	方法	描述
`void`	`onComplete()`	当已知对于还没有被错误终止的订阅不会发生额外的订户方法调用时，调用方法，之后订阅不会调用其他订阅者方法。
`void`	`onError(Throwable throwable)`	由发布商或订阅者遇到的不可恢复错误调用方法，之后订阅不会调用其他订阅者方法。
`void`	`onNext(T item)`	使用订阅的下一个项目调用的方法。
`void`	`onSubscribe(Flow.Subscription subscription)`	在调用给定订阅的任何其他订阅者方法之前调用的方法。

- 方法详细信息
  - onSubscribe
```
void onSubscribe(Flow.Subscription subscription)
```
    在调用给定订阅的任何其他订阅者方法之前调用的方法。如果此方法抛出异常，则不能保证产生的行为，但可能导致订阅不被建立或被取消。
    通常，该方法的实现调用subscription.request以启用接收项目。
    
    参数
    
    subscription - 新订阅
  - onNext
```
void onNext(T item)
```
    使用订阅的下一个项目调用的方法。如果此方法抛出异常，则不能保证产生的行为，但可能导致订阅被取消。
    
    参数
    
    item - 该项目
  - onError
```
void onError(Throwable throwable)
```
    由发布商或订阅者遇到的不可恢复错误调用方法，之后订阅不会调用其他订阅者方法。如果此方法本身引发异常，则导致行为未定义。
    
    参数
    
    throwable - 例外
  - onComplete
```
void onComplete()
```
    当已知对于还没有被错误终止的订阅不会发生额外的订户方法调用时，调用方法，之后订阅不会调用其他订阅者方法。如果此方法抛出异常，则导致行为未定义。