Class AbstractClientHttpRequest

All Implemented Interfaces:
ClientHttpRequest, HttpMessage, ReactiveHttpOutputMessage
Direct Known Subclasses:

public abstract class AbstractClientHttpRequest extends Object implements ClientHttpRequest
Base class for ClientHttpRequest implementations.
Rossen Stoyanchev, Brian Clozel
  • Constructor Details

    • AbstractClientHttpRequest

      public AbstractClientHttpRequest()
    • AbstractClientHttpRequest

      public AbstractClientHttpRequest(HttpHeaders headers)
  • Method Details

    • getHeaders

      public HttpHeaders getHeaders()
      Description copied from interface: HttpMessage
      Return the headers of this message.
      Specified by:
      getHeaders in interface HttpMessage
      a corresponding HttpHeaders object (never null)
    • initReadOnlyHeaders

      protected HttpHeaders initReadOnlyHeaders()
      Initialize the read-only headers after the request is committed.

      By default, this method simply applies a read-only wrapper. Subclasses can do the same for headers from the native request.

    • getCookies

      public MultiValueMap<String,HttpCookie> getCookies()
      Description copied from interface: ClientHttpRequest
      Return a mutable map of request cookies to send to the server.
      Specified by:
      getCookies in interface ClientHttpRequest
    • beforeCommit

      public void beforeCommit(Supplier<? extends reactor.core.publisher.Mono<Void>> action)
      Description copied from interface: ReactiveHttpOutputMessage
      Register an action to apply just before the HttpOutputMessage is committed.

      Note: the supplied action must be properly deferred, e.g. via Mono.defer(java.util.function.Supplier<? extends reactor.core.publisher.Mono<? extends T>>) or Mono.fromRunnable(java.lang.Runnable), to ensure it's executed in the right order, relative to other actions.

      Specified by:
      beforeCommit in interface ReactiveHttpOutputMessage
      action - the action to apply
    • isCommitted

      public boolean isCommitted()
      Description copied from interface: ReactiveHttpOutputMessage
      Whether the HttpOutputMessage is committed.
      Specified by:
      isCommitted in interface ReactiveHttpOutputMessage
    • doCommit

      protected reactor.core.publisher.Mono<Void> doCommit()
      A variant of doCommit(Supplier) for a request without body.
      a completion publisher
    • doCommit

      protected reactor.core.publisher.Mono<Void> doCommit(@Nullable Supplier<? extends Publisher<Void>> writeAction)
      Apply beforeCommit actions, apply the request headers/cookies, and write the request body.
      writeAction - the action to write the request body (may be null)
      a completion publisher
    • applyHeaders

      protected abstract void applyHeaders()
      Apply header changes from getHeaders() to the underlying request. This method is called once only.
    • applyCookies

      protected abstract void applyCookies()
      Add cookies from getHeaders() to the underlying request. This method is called once only.