-
- 含まれているクラス:
- Flow
public static interface Flow.Subscription
Flow.Publisher
とFlow.Subscriber
をリンクするメッセージ制御。 サブスクライブ者はリクエストがあった場合にのみ商品を受け取り、いつでも取り消すことができます。 このインタフェースのメソッドは、サブスクライバによってのみ呼び出されるようになっています。他の文脈での使用法には未定義の効果があります。
-
-
メソッドの詳細
-
request
void request(long n)
指定された番号のn
を、このサブスクリプションの現在の満たされていない需要に追加します。n
がゼロ以下の場合、サブスクライバはonError
信号をIllegalArgumentException
引数で受信します。 それ以外の場合、サブスクライバはn
まで追加のonNext
呼び出し(終了した場合はそれ以下)を受信します。- パラメータ:
n
- 需要の増加。Long.MAX_VALUE
の値は実質的に無制限と見なすことができます
-
cancel
void cancel()
(eventually)がメッセージの受信を停止するように、サブスクライバに指示します。 実装はベスト・エフォートです-- このメソッドを呼び出した後に追加のメッセージを受け取ることがあります。 取消されたサブスクリプションは、onComplete
またはonError
シグナルを受信する必要はありません。
-
-