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