- 含まれているクラス:
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()サブスクライバが(eventually)になり、メッセージの受信が停止します。 実装はベスト・エフォートです -- このメソッドを呼び出すと、追加のメッセージを受信できます。 取り消されたサブスクリプションは、onComplete
またはonError
シグナルを受信する必要はありません。
-