org.springframework.http.client.reactive

Class JettyClientHttpConnector

java.lang.Object

org.springframework.http.client.reactive.JettyClientHttpConnector

All Implemented Interfaces:

ClientHttpConnector

public class JettyClientHttpConnector
extends java.lang.Object
implements ClientHttpConnector

Jetty ReactiveStreams HttpClient implementation of ClientHttpConnector. Implemented with buffer copy instead of optimized buffer wrapping because the latter hangs since Callback.succeeded() doesn't allow releasing the buffer and requesting more data at different times (required for Mono<DataBuffer> for example). See https://github.com/eclipse/jetty.project/issues/2429 for more details.

Since:

5.1

Author:

Sebastien Deleuze

See Also:

Jetty ReactiveStreams HttpClient

Constructor Summary

Constructors

Constructor and Description
JettyClientHttpConnector() Default constructor that creates a new instance of HttpClient.
JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient) Constructor with an initialized HttpClient.
JettyClientHttpConnector(JettyResourceFactory resourceFactory, java.util.function.Consumer<org.eclipse.jetty.client.HttpClient> customizer) Constructor with an JettyResourceFactory that will manage shared resources.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<ClientHttpResponse>	connect(HttpMethod method, java.net.URI uri, java.util.function.Function<? super ClientHttpRequest,reactor.core.publisher.Mono<java.lang.Void>> 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JettyClientHttpConnector

public JettyClientHttpConnector()

Default constructor that creates a new instance of HttpClient.

JettyClientHttpConnector

public JettyClientHttpConnector(JettyResourceFactory resourceFactory,
                                @Nullable
                                java.util.function.Consumer<org.eclipse.jetty.client.HttpClient> customizer)

Constructor with an JettyResourceFactory that will manage shared resources.

Parameters:

resourceFactory - the JettyResourceFactory to use

customizer - the lambda used to customize the HttpClient

JettyClientHttpConnector

public JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient)

Constructor with an initialized HttpClient.

Method Detail

setBufferFactory

public void setBufferFactory(DataBufferFactory bufferFactory)

connect

public reactor.core.publisher.Mono<ClientHttpResponse> connect(HttpMethod method,
                                                               java.net.URI uri,
                                                               java.util.function.Function<? super ClientHttpRequest,reactor.core.publisher.Mono<java.lang.Void>> requestCallback)

Description copied from interface: ClientHttpConnector

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.

Specified by:

connect in interface ClientHttpConnector

Parameters:

method - the HTTP request method

uri - the HTTP request URI

requestCallback - 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(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>) or ReactiveHttpOutputMessage.setComplete().

Returns:

publisher for the ClientHttpResponse