モジュール java.base
パッケージ java.util.concurrent

インタフェースFlow.Subscription

含まれているクラス:
Flow
public static interface Flow.Subscription
Flow.PublisherとFlow.Subscriberをリンクするメッセージ制御。 サブスクライブ者はリクエストがあった場合にのみ商品を受け取り、いつでも取り消すことができます。 このインタフェースのメソッドは、サブスクライバによってのみ呼び出されるようになっています。他の文脈での使用法には未定義の効果があります。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    cancel()
    (eventually)がメッセージの受信を停止するように、サブスクライバに指示します。
    void
    request​(long n)
    指定された番号のnを、このサブスクリプションの現在の満たされていない需要に追加します。

  • メソッドの詳細

    • request

      void request​(long n)
      指定された番号のnを、このサブスクリプションの現在の満たされていない需要に追加します。 nがゼロ以下の場合、サブスクライバはonError信号をIllegalArgumentException引数で受信します。 それ以外の場合、サブスクライバはnまで追加の onNext呼び出し(終了した場合はそれ以下)を受信します。
      パラメータ:
      n - 需要の増加。 Long.MAX_VALUEの値は実質的に無制限と見なすことができます

    • cancel

      void cancel()
      (eventually)がメッセージの受信を停止するように、サブスクライバに指示します。 実装はベスト・エフォートです-- このメソッドを呼び出した後に追加のメッセージを受け取ることがあります。 取消されたサブスクリプションは、onCompleteまたはonErrorシグナルを受信する必要はありません。