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

インタフェース Flow.Subscriber<T>

  • 型パラメータ:
    T - サブスクライブされたアイテム・タイプ
    既知のすべてのサブインタフェース:
    Flow.Processor<T,​R>, HttpResponse.BodySubscriber<T>
    含まれているクラス:
    Flow

    public static interface Flow.Subscriber<T>
    メッセージの受信者。 このインタフェースのメソッドは、Flow.Subscriptionごとに厳密な順番で呼び出されます。
    • メソッドのサマリー

      すべてのメソッド インスタンス・メソッド 抽象メソッド 
      修飾子と型 メソッド 説明
      void onComplete()
      まだエラーで終了していないサブスクリプションに対して追加のSubscriberメソッド呼出しが発生しないことが判明している場合に起動されるメソッド。その後、サブスクリプションによって他のSubscriberメソッドは起動されません。
      void onError​(Throwable throwable)
      パブリッシャまたはサブスクリプションでリカバリ不能なエラーが発生した場合に呼び出されるメソッド。その後、サブスクリプションで他のサブスクライバ・メソッドは呼び出されません。
      void onNext​(T item)
      サブスクリプションの次のアイテムで呼び出されるメソッド。
      void onSubscribe​(Flow.Subscription subscription)
      指定されたサブスクリプションに対して他のサブスクライバ・メソッドを呼び出す前に呼び出されるメソッド。
    • メソッドの詳細

      • onSubscribe

        void onSubscribe​(Flow.Subscription subscription)
        指定されたサブスクリプションに対して他のサブスクライバ・メソッドを呼び出す前に呼び出されるメソッド。 このメソッドが例外をスローした場合、結果として生じる動作は保証されませんが、サブスクリプションが確立されないか、取り消される可能性があります。

        通常、このメソッドの実装では、 subscription.requestを起動してアイテムの受信を有効にします。

        パラメータ:
        subscription - 新規サブスクリプション
      • onNext

        void onNext​(T item)
        サブスクリプションの次のアイテムで呼び出されるメソッド。 このメソッドが例外をスローした場合、結果として生じる動作は保証されませんが、サブスクリプションが取り消される可能性があります。
        パラメータ:
        item - 項目
      • onError

        void onError​(Throwable throwable)
        パブリッシャまたはサブスクリプションでリカバリ不能なエラーが発生した場合に呼び出されるメソッド。その後、サブスクリプションで他のサブスクライバ・メソッドは呼び出されません。 このメソッド自体が例外をスローした場合、結果の動作は未定義になります。
        パラメータ:
        throwable - 例外
      • onComplete

        void onComplete()
        まだエラーで終了していないサブスクリプションに対して追加のSubscriberメソッド呼出しが発生しないことが判明している場合に起動されるメソッド。その後、サブスクリプションによって他のSubscriberメソッドは起動されません。 このメソッドが例外をスローすると、結果の動作は未定義になります。