-
- 参数类型
-
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()
当已知对于尚未由错误终止的订阅不会发生其他订阅者方法调用时调用的方法,之后订阅不会调用其他订阅者方法。 如果此方法抛出异常,则结果行为未定义。
-
-