Module java.base

软件包 java.util.concurrent

Interface Flow.Subscription

Enclosing class:

Flow

public static interface Flow.Subscription

消息控件链接Flow.Publisher和Flow.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.