public class ReactorServerHttpResponse extends AbstractServerHttpResponse implements ZeroCopyHttpOutputMessage
ServerHttpResponse to the Reactor Net HttpChannel.| Constructor and Description |
|---|
ReactorServerHttpResponse(reactor.ipc.netty.http.HttpChannel response,
DataBufferFactory dataBufferFactory) |
| Modifier and Type | Method and Description |
|---|---|
reactor.ipc.netty.http.HttpChannel |
getReactorChannel() |
protected reactor.core.publisher.Mono<Void> |
writeAndFlushWithInternal(org.reactivestreams.Publisher<org.reactivestreams.Publisher<DataBuffer>> publisher)
Implement this method to write to the underlying the response, and flush after
each
Publisher<DataBuffer>. |
protected void |
writeCookies()
Implement this method to add cookies from
AbstractServerHttpResponse.getHeaders() to the
underlying response. |
protected void |
writeHeaders()
Implement this method to apply header changes from
AbstractServerHttpResponse.getHeaders()
to the underlying response. |
protected void |
writeStatusCode()
Implement this method to write the status code to the underlying response.
|
reactor.core.publisher.Mono<Void> |
writeWith(File file,
long position,
long count)
Use the given
File to write the body of the message to the underlying
HTTP layer. |
protected reactor.core.publisher.Mono<Void> |
writeWithInternal(org.reactivestreams.Publisher<DataBuffer> publisher)
Implement this method to write to the underlying the response.
|
applyBeforeCommit, beforeCommit, bufferFactory, getCookies, getHeaders, getStatusCode, setComplete, setStatusCode, writeAndFlushWith, writeWithclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbeforeCommit, bufferFactory, setComplete, writeAndFlushWith, writeWithgetHeaderspublic ReactorServerHttpResponse(reactor.ipc.netty.http.HttpChannel response,
DataBufferFactory dataBufferFactory)
public reactor.ipc.netty.http.HttpChannel getReactorChannel()
protected void writeStatusCode()
AbstractServerHttpResponsewriteStatusCode in class AbstractServerHttpResponseprotected reactor.core.publisher.Mono<Void> writeWithInternal(org.reactivestreams.Publisher<DataBuffer> publisher)
AbstractServerHttpResponsewriteWithInternal in class AbstractServerHttpResponsepublisher - the publisher to write withprotected reactor.core.publisher.Mono<Void> writeAndFlushWithInternal(org.reactivestreams.Publisher<org.reactivestreams.Publisher<DataBuffer>> publisher)
AbstractServerHttpResponsePublisher<DataBuffer>.writeAndFlushWithInternal in class AbstractServerHttpResponsepublisher - the publisher to write and flush withprotected void writeHeaders()
AbstractServerHttpResponseAbstractServerHttpResponse.getHeaders()
to the underlying response. This method is called once only.writeHeaders in class AbstractServerHttpResponseprotected void writeCookies()
AbstractServerHttpResponseAbstractServerHttpResponse.getHeaders() to the
underlying response. This method is called once only.writeCookies in class AbstractServerHttpResponsepublic reactor.core.publisher.Mono<Void> writeWith(File file, long position, long count)
ZeroCopyHttpOutputMessageFile to write the body of the message to the underlying
HTTP layer.writeWith in interface ZeroCopyHttpOutputMessagefile - the file to transferposition - the position within the file from which the transfer is to begincount - the number of bytes to be transferred