インタフェースFlow.Subscription

含まれているクラス:
Flow
public static interface Flow.Subscription
Flow.PublisherとFlow.Subscriberをリンクするメッセージ制御。 サブスクライバは、リクエストされた場合にのみアイテムを受信し、いつでも取り消すことができます。 このインタフェースのメソッドは、サブスクライバによってのみ起動されます。他のコンテキストでの使用には、未定義の効果があります。
導入されたバージョン:
9

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    cancel()
    サブスクライバが(eventually)になり、メッセージの受信が停止します。
    void
    request(long n)
    指定された数のアイテムnを、このサブスクリプションの現在の未履行需要に追加します。

  • メソッドの詳細

    • request

      void request(long n)
      指定された数のアイテムnを、このサブスクリプションの現在の未履行需要に追加します。 nがゼロ以下の場合、サブスクライバはIllegalArgumentException引数を持つonErrorシグナルを受信します。 それ以外の場合、サブスクライバは最大nの追加の onNext呼出し(終了した場合はそれ以下)を受け取ります。
      パラメータ:
      n - 需要の増加。 Long.MAX_VALUEの値は実質的に無制限と見なすことができます

    • cancel

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