模块  java.base
软件包  java.util.concurrent

Interface Flow.Subscriber<T>

    • 方法摘要

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