-
- 含まれているクラス:
- Flow
public static interface Flow.SubscriptionFlow.PublisherとFlow.Subscriberをリンクするメッセージ制御。 サブスクライバは、リクエストされた場合にのみアイテムを受け取り、いつでもキャンセルできます。 このインタフェースのメソッドは、サブスクライバのみが呼び出すことを目的としています。他のコンテキストでの使用には、未定義の効果があります。
-
-
メソッドのサマリー
すべてのメソッド インスタンス・メソッド 抽象メソッド 修飾子と型 メソッド 説明 voidcancel()サブスクライバは、メッセージの受信を(最終的に)停止します。voidrequest(long n)指定されたアイテム数のnを、この登録の現在の未配送需要に追加します。
-
-
-
メソッドの詳細
-
request
void request(long n)
指定されたアイテム数のnを、この登録の現在の未配送需要に追加します。nが0以下の場合、サブスクライバはIllegalArgumentException引数を持つonErrorシグナルを受信します。 それ以外の場合、サブスクライバは最大n個の追加のonNext呼出しを受信します(終了した場合はそれ以下)。- パラメータ:
n- 需要の増分。値Long.MAX_VALUEは事実上無制限とみなされる。
-
cancel
void cancel()
サブスクライバは、メッセージの受信を(最終的に)停止します。 実装はベスト・エフォートです-- このメソッドの起動後に追加のメッセージを受信できます。 取り消されたサブスクリプションは、onCompleteまたはonErrorシグナルを受信する必要はありません。
-
-