public abstract class AbstractListenerServerHttpResponse extends AbstractServerHttpResponse
logger
コンストラクターと説明 |
---|
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory) |
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers) |
修飾子と型 | メソッドと説明 |
---|---|
protected abstract org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,VoidSE> | createBodyFlushProcessor() 基になる出力にフラッシュしてレスポンス本文を書き込む Processor<Publisher<DataBuffer>, Void> を作成する抽象テンプレートメソッド。 |
protected reactor.core.publisher.Mono<VoidSE> | writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body) 基本となるレスポンスに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。 |
protected reactor.core.publisher.Mono<VoidSE> | writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> body) 基本となるレスポンスに書き込みます。 |
addCookie, applyCookies, applyHeaders, applyStatusCode, beforeCommit, bufferFactory, doCommit, doCommit, getCookies, getHeaders, getNativeResponse, getStatusCode, getStatusCodeValue, isCommitted, setComplete, setStatusCode, setStatusCodeValue, writeAndFlushWith, writeWith
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers)
protected final reactor.core.publisher.Mono<VoidSE> writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> body)
AbstractServerHttpResponse
AbstractServerHttpResponse
の writeWithInternal
body
- 一緒に書くパブリッシャー protected final reactor.core.publisher.Mono<VoidSE> writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
AbstractServerHttpResponse
Publisher<DataBuffer>
の後にフラッシュします。AbstractServerHttpResponse
の writeAndFlushWithInternal
body
- 書き込みおよびフラッシュするパブリッシャー protected abstract org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,VoidSE> createBodyFlushProcessor()
Processor<Publisher<DataBuffer>, Void>
を作成する抽象テンプレートメソッド。writeAndFlushWithInternal(Publisher)
から呼び出されます。