类 AbstractListenerWriteFlushProcessor<T>

字段详细资料

• rsWriteFlushLogger

  protected static final Log rsWriteFlushLogger

  Special logger for debugging Reactive Streams signals.

  另请参阅:

  LogDelegateFactory.getHiddenLog(Class), AbstractListenerReadPublisher.rsReadLogger, AbstractListenerWriteProcessor.rsWriteLogger, WriteResultPublisher.rsWriteResultLogger

构造器详细资料

• AbstractListenerWriteFlushProcessor

  public AbstractListenerWriteFlushProcessor()

• AbstractListenerWriteFlushProcessor

  public AbstractListenerWriteFlushProcessor​(String logPrefix)

  Create an instance with the given log prefix.

  从以下版本开始:

  5.1

方法详细资料

• getLogPrefix

  public String getLogPrefix()

  Create an instance with the given log prefix.

  从以下版本开始:

  5.1

• onSubscribe

  public final void onSubscribe​(org.reactivestreams.Subscription subscription)

  指定者:

  onSubscribe 在接口中 org.reactivestreams.Subscriber<T>

• onNext

  public final void onNext​(org.reactivestreams.Publisher<? extends T> publisher)

  指定者:

  onNext 在接口中 org.reactivestreams.Subscriber<T>

• onError

  public final void onError​(Throwable ex)

  Error signal from the upstream, write Publisher. This is also used by sub-classes to delegate error notifications from the container.

  指定者:

  onError 在接口中 org.reactivestreams.Subscriber<T>

• onComplete

  public final void onComplete()

  Completion signal from the upstream, write Publisher. This is also used by sub-classes to delegate completion notifications from the container.

  指定者:

  onComplete 在接口中 org.reactivestreams.Subscriber<T>

• onFlushPossible

  protected final void onFlushPossible()

  Invoked when flushing is possible, either in the same thread after a check via isWritePossible(), or as a callback from the underlying container.

• cancel

  protected void cancel()

  Invoked during an error or completion callback from the underlying container to cancel the upstream subscription.

• subscribe

  public final void subscribe​(org.reactivestreams.Subscriber<? super Void> subscriber)

  指定者:

  subscribe 在接口中 org.reactivestreams.Publisher<T>

• createWriteProcessor

  protected abstract org.reactivestreams.Processor<? super T,​Void> createWriteProcessor()

  Create a new processor for the current flush boundary.

• isWritePossible

  protected abstract boolean isWritePossible()

  Whether writing/flushing is possible.

• flush

  protected abstract void flush()
                         throws IOException

  Flush the output if ready, or otherwise isFlushPending() should return true after.

  This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.

  抛出:

  IOException

• isFlushPending

  protected abstract boolean isFlushPending()

  Whether flushing is pending.

  This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.

• flushingFailed

  protected void flushingFailed​(Throwable t)

  Invoked when an error happens while flushing. Sub-classes may choose to ignore this if they know the underlying API will provide an error notification in a container thread.

  Defaults to no-op.