class ReactorClientHttpRequest extends AbstractClientHttpRequest implements ZeroCopyHttpOutputMessage
ClientHttpRequest implementation for the Reactor-Netty HTTP client.reactor.netty.http.client.HttpClient| Modifier and Type | Field and Description |
|---|---|
private NettyDataBufferFactory |
bufferFactory |
private HttpMethod |
httpMethod |
private NettyOutbound |
outbound |
private HttpClientRequest |
request |
private java.net.URI |
uri |
| Constructor and Description |
|---|
ReactorClientHttpRequest(HttpMethod method,
java.net.URI uri,
HttpClientRequest request,
NettyOutbound outbound) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
applyCookies()
Add cookies from
AbstractClientHttpRequest.getHeaders() to the underlying response. |
protected void |
applyHeaders()
Apply header changes from
AbstractClientHttpRequest.getHeaders() to the underlying response. |
DataBufferFactory |
bufferFactory()
Return a
DataBufferFactory that can be used to create the body. |
HttpMethod |
getMethod()
Return the HTTP method of the request.
|
java.net.URI |
getURI()
Return the URI of the request.
|
<any> |
setComplete()
Indicate that message handling is complete, allowing for any cleanup or
end-of-processing tasks to be performed such as applying header changes
made via
HttpMessage.getHeaders() to the underlying HTTP message (if not
applied already). |
private static <any> |
toByteBufs(<any> dataBuffers) |
<any> |
writeAndFlushWith(<any> body)
Use the given
Publisher of Publishers to write the body
of the HttpOutputMessage to the underlying HTTP layer, flushing after
each Publisher<DataBuffer>. |
<any> |
writeWith(<any> body)
Use the given
Publisher to write the body of the message to the
underlying HTTP layer. |
<any> |
writeWith(java.nio.file.Path file,
long position,
long count)
Use the given
Path to write the body of the message to the underlying
HTTP layer. |
beforeCommit, doCommit, doCommit, getCookies, getHeaders, isCommittedclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitwriteWithbeforeCommit, isCommittedgetHeadersprivate final HttpMethod httpMethod
private final java.net.URI uri
private final HttpClientRequest request
private final NettyOutbound outbound
private final NettyDataBufferFactory bufferFactory
public ReactorClientHttpRequest(HttpMethod method, java.net.URI uri, HttpClientRequest request, NettyOutbound outbound)
public DataBufferFactory bufferFactory()
ReactiveHttpOutputMessageDataBufferFactory that can be used to create the body.bufferFactory in interface ReactiveHttpOutputMessage#writeWith(Publisher)public HttpMethod getMethod()
ClientHttpRequestgetMethod in interface ClientHttpRequestpublic java.net.URI getURI()
ClientHttpRequestgetURI in interface ClientHttpRequestpublic <any> writeWith(<any> body)
ReactiveHttpOutputMessagePublisher to write the body of the message to the
underlying HTTP layer.writeWith in interface ReactiveHttpOutputMessagebody - the body content publisherMono that indicates completion or errorpublic <any> writeAndFlushWith(<any> body)
ReactiveHttpOutputMessagePublisher of Publishers to write the body
of the HttpOutputMessage to the underlying HTTP layer, flushing after
each Publisher<DataBuffer>.writeAndFlushWith in interface ReactiveHttpOutputMessagebody - the body content publisherMono that indicates completion or errorprivate static <any> toByteBufs(<any> dataBuffers)
public <any> writeWith(java.nio.file.Path file,
long position,
long count)
ZeroCopyHttpOutputMessagePath 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 transferredpublic <any> setComplete()
ReactiveHttpOutputMessageHttpMessage.getHeaders() to the underlying HTTP message (if not
applied already).
This method should be automatically invoked at the end of message processing so typically applications should not have to invoke it. If invoked multiple times it should have no side effects.
setComplete in interface ReactiveHttpOutputMessageMono that indicates completion or errorprotected void applyHeaders()
AbstractClientHttpRequestAbstractClientHttpRequest.getHeaders() to the underlying response.
This method is called once only.applyHeaders in class AbstractClientHttpRequestprotected void applyCookies()
AbstractClientHttpRequestAbstractClientHttpRequest.getHeaders() to the underlying response.
This method is called once only.applyCookies in class AbstractClientHttpRequest