モジュール 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()	まだエラーによって終了されていないサブスクリプションに対して追加のサブスクライバ・メソッド呼出しが発生しないことがわかっている場合に呼び出されるメソッド。その後、サブスクリプションによって他のサブスクライバ・メソッドが呼び出されることはありません。
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()

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