モジュール 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シグナルを受信する必要はありません。