モジュール 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メソッドがサブスクリプションによって呼び出されていないことが判明した場合に呼び出されるメソッド。
    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メソッドがサブスクリプションによって呼び出されていないことが判明した場合に呼び出されるメソッド。 このメソッドが例外をスローした場合、結果の動作は未定義です。