-
- Enclosing class:
- Flow
public static interface Flow.Subscription
消息控制链接Flow.Publisher
和Flow.Subscriber
。 订阅者只有在被要求时才会收到项目,并且可以随时取消。 此接口中的方法仅由其订阅者调用; 其他环境中的用法具有不确定的效果。
-
-
方法详细信息
-
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 anonComplete
oronError
signal.
-
-