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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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