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

Interface Flow.Subscription

  • Enclosing class:
    Flow

    public static interface Flow.Subscription
    消息控制链接Flow.PublisherFlow.Subscriber 订阅者只有在被要求时才会收到项目,并且可以随时取消。 此接口中的方法仅由其订阅者调用; 其他环境中的用法具有不确定的效果。
    • 方法摘要

      所有方法  实例方法 抽象方法 
      变量和类型 方法 描述
      void cancel()
      导致订阅服务器(最终)停止接收消息。
      void request​(long n)
      将给定数量的项目 n添加到此订阅的当前未履行需求中。
    • 方法详细信息

      • request

        void request​(long n)
        将给定数量的项目n添加到此订阅的当前未履行需求中。 如果n小于或等于零,则订户将收到带有IllegalArgumentException参数的onError信号。 否则,订户将接收最多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.