方法详细信息

• 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()

  当已知对于尚未由错误终止的订阅不会发生其他订阅者方法调用时调用的方法，之后订阅不会调用其他订阅者方法。 如果此方法抛出异常，则结果行为未定义。