public class RxNettyServerHttpResponse extends AbstractServerHttpResponse
ServerHttpResponse to the RxNetty HttpServerResponse.| Modifier and Type | Class and Description |
|---|---|
private class |
RxNettyServerHttpResponse.FlushSelector |
| Modifier and Type | Field and Description |
|---|---|
private static ByteBuf |
FLUSH_SIGNAL |
private static long |
FLUSH_THRESHOLD |
private <any> |
response |
| Constructor and Description |
|---|
RxNettyServerHttpResponse(<any> response,
NettyDataBufferFactory dataBufferFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
applyCookies()
Implement this method to add cookies from
AbstractServerHttpResponse.getHeaders() to the
underlying response. |
protected void |
applyHeaders()
Implement this method to apply header changes from
AbstractServerHttpResponse.getHeaders()
to the underlying response. |
protected void |
applyStatusCode()
Implement this method to write the status code to the underlying response.
|
<any> |
getRxNettyResponse() |
protected <any> |
writeAndFlushWithInternal(<any> body)
Implement this method to write to the underlying the response, and flush after
each
Publisher<DataBuffer>. |
protected <any> |
writeWithInternal(<any> body)
Implement this method to write to the underlying the response.
|
beforeCommit, bufferFactory, doCommit, doCommit, encodeUrl, getCookies, getHeaders, getStatusCode, isCommitted, registerUrlEncoder, setComplete, setStatusCode, writeAndFlushWith, writeWithprivate final <any> response
private static final ByteBuf FLUSH_SIGNAL
private static final long FLUSH_THRESHOLD
public RxNettyServerHttpResponse(<any> response,
NettyDataBufferFactory dataBufferFactory)
public <any> getRxNettyResponse()
protected void applyStatusCode()
AbstractServerHttpResponseapplyStatusCode in class AbstractServerHttpResponseprotected <any> writeWithInternal(<any> body)
AbstractServerHttpResponsewriteWithInternal in class AbstractServerHttpResponsebody - the publisher to write withprotected <any> writeAndFlushWithInternal(<any> body)
AbstractServerHttpResponsePublisher<DataBuffer>.writeAndFlushWithInternal in class AbstractServerHttpResponsebody - the publisher to write and flush withprotected void applyHeaders()
AbstractServerHttpResponseAbstractServerHttpResponse.getHeaders()
to the underlying response. This method is called once only.applyHeaders in class AbstractServerHttpResponseprotected void applyCookies()
AbstractServerHttpResponseAbstractServerHttpResponse.getHeaders() to the
underlying response. This method is called once only.applyCookies in class AbstractServerHttpResponse