Flow.Subscriber

参数类型

T - 订阅的项目类型

All Known Subinterfaces:

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

Enclosing class:

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

方法摘要

所有方法实例方法抽象方法
变量和类型	方法	描述
`void`	`onComplete()`	当已知对于尚未由错误终止的订阅不会发生其他订阅者方法调用时调用的方法，之后订阅不会调用其他订阅者方法。
`void`	`onError(Throwable throwable)`	在发布者或订阅服务器遇到不可恢复的错误时调用的方法，之后订阅服务器不会调用其他订阅服务器方法。
`void`	`onNext(T item)`	使用Subscription的下一个项目调用的方法。
`void`	`onSubscribe(Flow.Subscription subscription)`	在为给定的Subscription调用任何其他Subscriber方法之前调用的方法。

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