クラス AbstractListenerWriteFlushProcessor<T>

メソッドの詳細

• getLogPrefix

  public StringSE getLogPrefix()

  指定されたログプレフィックスでインスタンスを作成します。

  導入:

  5.1

• onSubscribe

  public final void onSubscribe(Subscription subscription)

  次で指定:

  インターフェース Subscriber<T> の onSubscribe 

• onNext

  public final void onNext(Publisher<? extends T> publisher)

  次で指定:

  インターフェース Subscriber<T> の onNext 

• onError

  public final void onError(ThrowableSE ex)

  アップストリームからのエラー信号、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

  public final void subscribe(Subscriber<? super VoidSE> subscriber)

  次で指定:

  インターフェース Publisher<T> の 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 がダウンストリームに送信されます。