Module java.base
Package java.util.concurrent

Interface Flow.Subscription

封装类:
Flow
public static interface Flow.Subscription
消息控制，连接一个Flow.Publisher和一个Flow.Subscriber。订阅者只有在请求时才会接收到项目，并且可以随时取消。此接口中的方法仅应由其订阅者调用；在其他上下文中使用会产生未定义的效果。

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cancel()
    导致订阅者（最终）停止接收消息。
    void
    request(long n)
    将给定数量n的项目添加到此订阅的当前未满足需求中。

  • Method Details

    • request

      void request(long n)
      将给定数量n的项目添加到此订阅的当前未满足需求中。如果n小于或等于零，则订阅者将收到一个带有IllegalArgumentException参数的onError信号。否则，订阅者将最多收到n个额外的onNext调用（如果终止，则更少）。
      参数:
      n - 需求的增量；Long.MAX_VALUE的值可以被视为有效无限

    • cancel

      void cancel()
      导致订阅者（最终）停止接收消息。实现是尽力而为的 -- 在调用此方法后可能会接收到额外的消息。取消的订阅不一定会收到onComplete或onError信号。