AbstractListenerWriteFlushProcessor (Spring Framework API)

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 static Log rsWriteFlushLogger
Reactive Streams 信号をデバッグするための特別なロガー。

フィールド
修飾子と型	フィールドと説明
`protected static Log`	`rsWriteFlushLogger` Reactive Streams 信号をデバッグするための特別なロガー。

コンストラクターのサマリー

コンストラクター
コンストラクターと説明
`AbstractListenerWriteFlushProcessor()`
`AbstractListenerWriteFlushProcessor(StringSE logPrefix)` 指定されたログプレフィックスでインスタンスを作成します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド抽象メソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`cancel()` サーブレットコンテナーのエラー / 完了通知などが原因で、「書き込み」パブリッシャーのアップストリームチェーンのみをキャンセルします。
`protected abstract Processor<? super T, VoidSE>`	`createWriteProcessor()` 現在のフラッシュ境界の新しいプロセッサーを作成します。
`protected abstract void`	`flush()` 準備ができている場合は出力をフラッシュします。そうでない場合、`isFlushPending()` は後で true を返します。
`protected void`	`flushingFailed(ThrowableSE t)` フラッシュ中にエラーが発生すると呼び出されます。
`StringSE`	`getLogPrefix()` 指定されたログプレフィックスでインスタンスを作成します。
`protected abstract boolean`	`isFlushPending()` フラッシュが保留中かどうか。
`protected abstract boolean`	`isWritePossible()` 書き込み / フラッシュが可能かどうか。
`void`	`onComplete()` アップストリームからの補完信号、パブリッシャーに書き込みます。
`void`	`onError(ThrowableSE ex)` アップストリームからのエラー信号、パブリッシャーに書き込みます。
`protected void`	`onFlushPossible()` フラッシュが可能なときに呼び出されます。`isWritePossible()` を介してチェックした後、同じスレッドで実行されるか、基になるコンテナーからのコールバックとして実行されます。
`void`	`onNext(Publisher<? extends T> publisher)`
`void`	`onSubscribe(Subscription subscription)`
`void`	`subscribe(Subscriber<? super VoidSE> subscriber)`

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE

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

クラス AbstractListenerWriteFlushProcessor<T>

フィールドサマリー

コンストラクターのサマリー

メソッドのサマリー

クラス java.lang.ObjectSE から継承されたメソッド

フィールドの詳細

rsWriteFlushLogger

コンストラクターの詳細

AbstractListenerWriteFlushProcessor

AbstractListenerWriteFlushProcessor

メソッドの詳細

getLogPrefix

onSubscribe

onNext

onError

onComplete

onFlushPossible

cancel

subscribe

createWriteProcessor

isWritePossible

flush

isFlushPending

flushingFailed