クラス AbstractListenerWriteFlushProcessor<T>
java.lang.ObjectSE
org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor<T>
- 型パラメーター:
T
-Subscriber
に通知される要素の型
- 実装されたすべてのインターフェース:
Processor<Publisher<? extends T>,
、VoidSE> Publisher<VoidSE>
、Subscriber<Publisher<? extends T>>
public abstract class AbstractListenerWriteFlushProcessor<T>
extends ObjectSE
implements Processor<Publisher<? extends T>,VoidSE>
AbstractListenerWriteProcessor
の代替ですが、代わりにフラッシュ境界を使用して Publisher<Publisher<T>>
を記述すると、ネストされた各パブリッシャーの補完後に強制されます。- 導入:
- 5.0
- 作成者:
- Arjen Poutsma, Violeta Georgieva, Rossen Stoyanchev
フィールドサマリー
フィールドコンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected void
cancel()
サーブレットコンテナーのエラー / 完了通知などが原因で、「書き込み」パブリッシャーのアップストリームチェーンのみをキャンセルします。現在のフラッシュ境界の新しいプロセッサーを作成します。protected abstract void
flush()
準備ができている場合は出力をフラッシュします。そうでない場合、isFlushPending()
は後で true を返します。protected void
フラッシュ中にエラーが発生すると呼び出されます。指定されたログプレフィックスでインスタンスを作成します。protected abstract boolean
フラッシュが保留中かどうか。protected abstract boolean
書き込み / フラッシュが可能かどうか。final void
アップストリームからの補完シグナル、パブリッシャーに書き込みます。final void
onError
(ThrowableSE ex) アップストリームからのエラーシグナル、パブリッシャーに書き込みます。protected final void
フラッシュが可能なときに呼び出されます。isWritePossible()
を介してチェックした後、同じスレッドで実行されるか、基になるコンテナーからのコールバックとして実行されます。final void
final void
onSubscribe
(Subscription subscription) final void
subscribe
(Subscriber<? super VoidSE> subscriber)
フィールドの詳細
rsWriteFlushLogger
Reactive Streams シグナルをデバッグするための特別なロガー。- 関連事項:
LogDelegateFactory.getHiddenLog(Class)
AbstractListenerReadPublisher.rsReadLogger
AbstractListenerWriteProcessor.rsWriteLogger
WriteResultPublisher.rsWriteResultLogger
コンストラクターの詳細
AbstractListenerWriteFlushProcessor
public AbstractListenerWriteFlushProcessor()AbstractListenerWriteFlushProcessor
指定されたログプレフィックスでインスタンスを作成します。- 導入:
- 5.1
メソッドの詳細
getLogPrefix
指定されたログプレフィックスでインスタンスを作成します。- 導入:
- 5.1
onSubscribe
- 次で指定:
- インターフェース
Subscriber<T>
のonSubscribe
onNext
- 次で指定:
- インターフェース
Subscriber<T>
のonNext
onError
アップストリームからのエラーシグナル、Publisher を書き込みます。これは、コンテナーからのエラー通知を委譲するためにサブクラスでも使用されます。- 次で指定:
- インターフェース
Subscriber<T>
のonError
onComplete
public final void onComplete()アップストリームからの補完シグナル、Publisher を書き込みます。これは、コンテナーからの補完通知を委譲するためにサブクラスでも使用されます。- 次で指定:
- インターフェース
Subscriber<T>
のonComplete
onFlushPossible
protected final void onFlushPossible()フラッシュが可能なときに呼び出されます。isWritePossible()
を介してチェックした後、同じスレッドで実行されるか、基になるコンテナーからのコールバックとして実行されます。cancel
protected void cancel()サーブレットコンテナーのエラー / 完了通知などが原因で、「書き込み」パブリッシャーのアップストリームチェーンのみをキャンセルします。これは通常、onError(Throwable)
またはonComplete()
のいずれかを呼び出して、ダウンストリームチェーンに通知する必要があります。つまり、ダウンストリームからキャンセルが発生した場合を除きます。subscribe
createWriteProcessor
現在のフラッシュ境界の新しいプロセッサーを作成します。isWritePossible
protected abstract boolean isWritePossible()書き込み / フラッシュが可能かどうか。flush
準備ができている場合は出力をフラッシュします。そうでない場合、isFlushPending()
は後で true を返します。これは主に、readyToWrite チェックなしではフラッシュを呼び出せないサーブレットのノンブロッキング I/O API 向けです。
isFlushPending
protected abstract boolean isFlushPending()フラッシュが保留中かどうか。これは主に、readyToWrite チェックなしではフラッシュを呼び出せないサーブレットのノンブロッキング I/O API 向けです。
flushingFailed
フラッシュ中にエラーが発生すると呼び出されます。デフォルトの実装では、アップストリーム書き込みパブリッシャーをキャンセルし、リクエスト処理の結果として onError をダウンストリームに送信します。