public class ReactorClientHttpConnector extends java.lang.Object implements ClientHttpConnector
ClientHttpConnector
.reactor.ipc.netty.http.client.HttpClient
Modifier and Type | Field and Description |
---|---|
private HttpClient |
httpClient |
Constructor and Description |
---|
ReactorClientHttpConnector()
Create a Reactor Netty
ClientHttpConnector
with default ClientOptions and HTTP compression support enabled. |
ReactorClientHttpConnector(java.util.function.Consumer<? super HttpClientOptions.Builder> clientOptions)
Create a Reactor Netty
ClientHttpConnector with the given
HttpClientOptions.Builder |
Modifier and Type | Method and Description |
---|---|
private io.netty.handler.codec.http.HttpMethod |
adaptHttpMethod(HttpMethod method) |
private ReactorClientHttpRequest |
adaptRequest(HttpMethod method,
java.net.URI uri,
HttpClientRequest request) |
private ClientHttpResponse |
adaptResponse(HttpClientResponse response) |
<any> |
connect(HttpMethod method,
java.net.URI uri,
java.util.function.Function<? super ClientHttpRequest,<any>> requestCallback)
Connect to the origin server using the given
HttpMethod and
URI , then apply the given requestCallback on the
ClientHttpRequest once the connection has been established. |
public ReactorClientHttpConnector()
ClientHttpConnector
with default ClientOptions
and HTTP compression support enabled.public ReactorClientHttpConnector(java.util.function.Consumer<? super HttpClientOptions.Builder> clientOptions)
ClientHttpConnector
with the given
HttpClientOptions.Builder
public <any> connect(HttpMethod method, java.net.URI uri, java.util.function.Function<? super ClientHttpRequest,<any>> requestCallback)
ClientHttpConnector
HttpMethod
and
URI
, then apply the given requestCallback
on the
ClientHttpRequest
once the connection has been established.
Return a publisher of the ClientHttpResponse
.
connect
in interface ClientHttpConnector
method
- the HTTP request methoduri
- the HTTP request URIrequestCallback
- a function that prepares and writes the request,
returning a publisher that signals when it's done interacting with the
request. Implementations should return a Mono<Void>
by calling
ReactiveHttpOutputMessage.writeWith(<any>)
or ReactiveHttpOutputMessage.setComplete()
.ClientHttpResponse
private io.netty.handler.codec.http.HttpMethod adaptHttpMethod(HttpMethod method)
private ReactorClientHttpRequest adaptRequest(HttpMethod method, java.net.URI uri, HttpClientRequest request)
private ClientHttpResponse adaptResponse(HttpClientResponse response)