public class JettyClientHttpConnector extends java.lang.Object implements ClientHttpConnector
ClientHttpConnector
for the Jetty Reactive Streams HttpClient.Modifier and Type | Field and Description |
---|---|
private DataBufferFactory |
bufferFactory |
private HttpClient |
httpClient |
Constructor and Description |
---|
JettyClientHttpConnector()
Default constructor that creates a new instance of
HttpClient . |
JettyClientHttpConnector(HttpClient httpClient)
Constructor with an initialized
HttpClient . |
JettyClientHttpConnector(JettyResourceFactory resourceFactory,
java.util.function.Consumer<HttpClient> customizer)
Constructor with an
JettyResourceFactory that will manage shared resources. |
Modifier and Type | Method and Description |
---|---|
<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 and apply the given requestCallback when the HTTP
request of the underlying API can be initialized and written to. |
void |
setBufferFactory(DataBufferFactory bufferFactory) |
private DataBuffer |
toDataBuffer(ContentChunk chunk) |
private final HttpClient httpClient
private DataBufferFactory bufferFactory
public JettyClientHttpConnector()
HttpClient
.public JettyClientHttpConnector(JettyResourceFactory resourceFactory, @Nullable java.util.function.Consumer<HttpClient> customizer)
JettyResourceFactory
that will manage shared resources.resourceFactory
- the JettyResourceFactory
to usecustomizer
- the lambda used to customize the HttpClient
public JettyClientHttpConnector(HttpClient httpClient)
HttpClient
.public void setBufferFactory(DataBufferFactory bufferFactory)
public <any> connect(HttpMethod method, java.net.URI uri, java.util.function.Function<? super ClientHttpRequest,<any>> requestCallback)
ClientHttpConnector
HttpMethod
and
URI
and apply the given requestCallback
when the HTTP
request of the underlying API can be initialized and written to.connect
in interface ClientHttpConnector
method
- the HTTP request methoduri
- the HTTP request URIrequestCallback
- a function that prepares and writes to the request,
returning a publisher that signals when it's done writing.
Implementations can return a Mono<Void>
by calling
ReactiveHttpOutputMessage.writeWith(<any>)
or ReactiveHttpOutputMessage.setComplete()
.ClientHttpResponse
private DataBuffer toDataBuffer(ContentChunk chunk)