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

Interface Flow.Subscription

  • Enclosing class:
    Flow


    public static interface Flow.Subscription
    消息控件链接Flow.PublisherFlow.Subscriber 订阅者仅在请求时才收到项目,并可随时取消。 此接口中的方法仅由其订阅者调用; 在其他情况下的用法具有未定义的效果。
    • 方法摘要

      所有方法  接口方法  抽象方法 
      Modifier and Type 方法 描述
      void cancel​()
      使订阅者(最终)停止接收消息。
      void request​(long n)
      将给定数 n项目为这个订阅目前未实现的需求。
    • 方法详细信息

      • request

        void request​(long n)
        将给定数量的n项目添加到此订阅的当前未实现的需求中。 如果n小于或等于零,则订户将收到onError信号与IllegalArgumentException参数。 否则,订阅者最多可以收到n额外的onNext调用(如果终止则更少)。
        参数
        n - 需求增量 价值Long.MAX_VALUE可能被视为有效无限
      • cancel

        void cancel​()
        Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an onComplete or onError signal.