模块 java.base

包 java.util.concurrent

接口 Flow.Subscription

封闭类：

Flow

public static interface Flow.Subscription
      

链接 Flow.Publisher 和 Flow.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()
            

导致订阅者（最终）停止接收消息。实现是尽力而为——调用此方法后可能会收到其他消息。取消的订阅不需要收到 onComplete 或 onError 信号。