public abstract class AbstractListenerServerHttpResponse extends AbstractServerHttpResponse
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicBoolean |
writeCalled |
logger
Constructor and Description |
---|
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory) |
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory,
HttpHeaders headers) |
Modifier and Type | Method and Description |
---|---|
protected abstract <any> |
createBodyFlushProcessor()
Abstract template method to create a
Processor<Publisher<DataBuffer>, Void>
that will write the response body with flushes to the underlying output. |
protected <any> |
writeAndFlushWithInternal(<any> body)
Write to the underlying the response, and flush after each
Publisher<DataBuffer> . |
protected <any> |
writeWithInternal(<any> body)
Write to the underlying the response.
|
addCookie, applyCookies, applyHeaders, applyStatusCode, beforeCommit, bufferFactory, doCommit, doCommit, getCookies, getHeaders, getNativeResponse, getStatusCode, getStatusCodeValue, isCommitted, setComplete, setStatusCode, setStatusCodeValue, writeAndFlushWith, writeWith
public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers)
protected final <any> writeWithInternal(<any> body)
AbstractServerHttpResponse
writeWithInternal
in class AbstractServerHttpResponse
body
- the publisher to write withprotected final <any> writeAndFlushWithInternal(<any> body)
AbstractServerHttpResponse
Publisher<DataBuffer>
.writeAndFlushWithInternal
in class AbstractServerHttpResponse
body
- the publisher to write and flush withprotected abstract <any> createBodyFlushProcessor()
Processor<Publisher<DataBuffer>, Void>
that will write the response body with flushes to the underlying output. Called from
#writeAndFlushWithInternal(Publisher)
.