Module  java.base
软件包  java.util.concurrent

Interface Flow.Subscriber<T>

    • 方法摘要

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