フィールドの詳細

• rsReadLogger

  protected static Log rsReadLogger

  Reactive Streams 信号をデバッグするための特別なロガー。

  関連事項:

  LogDelegateFactory.getHiddenLog(Class), AbstractListenerWriteProcessor.rsWriteLogger, AbstractListenerWriteFlushProcessor.rsWriteFlushLogger, WriteResultPublisher.rsWriteResultLogger

コンストラクターの詳細

• AbstractListenerReadPublisher

  public AbstractListenerReadPublisher()

• AbstractListenerReadPublisher

  public AbstractListenerReadPublisher(StringSE logPrefix)

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

  導入:

  5.1

メソッドの詳細

• getLogPrefix

  public StringSE getLogPrefix()

  設定されたログメッセージプレフィックスを返します。

  導入:

  5.1

• subscribe

  public void subscribe(Subscriber<? super T> subscriber)

  次で指定:

  インターフェース Publisher<T> の subscribe 

• onDataAvailable

  public final void onDataAvailable()

  checkOnDataAvailable() によるチェックの後、同じスレッドで、基盤となるコンテナーからのコールバックとして、読み取りが可能なときに呼び出されます。

• onAllDataRead

  public void onAllDataRead()

  サブクラスは、このメソッドを呼び出して、すべてのデータが読み取られたときに包含通知を委譲できます。

• onError

  public final void onError(ThrowableSE ex)

  サブクラスはこれを呼び出して、コンテナーエラー通知を委譲できます。

• checkOnDataAvailable

  protected abstract void checkOnDataAvailable()

  データが利用可能かどうかを確認し、onDataAvailable() をすぐに呼び出すか、通知をスケジュールします。

• read

  @Nullable
  protected abstract T read()
                               throws IOExceptionSE

  可能であれば、入力から 1 回読み取ります。

  戻り値:

  読み込まれたアイテム。または null

  例外:

  IOExceptionSE

• readingPaused

  protected abstract void readingPaused()

  要求がなかったために読み取りが一時停止されたときに呼び出されます。

  注意 : このメソッドは checkOnDataAvailable() と競合しないことが保証されているため、基になる API がサポートしている場合、つまり checkOnDataAvailable() を介して再開する暗黙的な呼び出しと競合することなく、安全に読み取りを中断できます。

  導入:

  5.0.2

• discardData

  protected abstract void discardData()

  基になるサーバーからの I/O 読み取りエラーの後、またはダウンストリームコンシューマーからのキャンセル信号の後に呼び出され、サブクラスが現在のキャッシュデータを破棄できるようにします。

  導入:

  5.0.11