Class DefaultClient

core/src/main/java/feign/DefaultClient.java:44–240

import javax.net.ssl.SSLSocketFactory;

public class DefaultClient implements Client {

  private final SSLSocketFactory sslContextFactory;
  private final HostnameVerifier hostnameVerifier;

  /**
   * Disable the request body internal buffering for {@code HttpURLConnection}.
   *
   * @see HttpURLConnection#setFixedLengthStreamingMode(int)
   * @see HttpURLConnection#setFixedLengthStreamingMode(long)
   * @see HttpURLConnection#setChunkedStreamingMode(int)
   */
  private final boolean disableRequestBuffering;

  /**
   * Create a new client, which disable request buffering by default.
   *
   * @param sslContextFactory SSLSocketFactory for secure https URL connections.
   * @param hostnameVerifier the host name verifier.
   */
  public DefaultClient(SSLSocketFactory sslContextFactory, HostnameVerifier hostnameVerifier) {
    this.sslContextFactory = sslContextFactory;
    this.hostnameVerifier = hostnameVerifier;
    this.disableRequestBuffering = true;
  }

  /**
   * Create a new client.
   *
   * @param sslContextFactory SSLSocketFactory for secure https URL connections.
   * @param hostnameVerifier the host name verifier.
   * @param disableRequestBuffering Disable the request body internal buffering for {@code
   *     HttpURLConnection}.
   */
  public DefaultClient(
      SSLSocketFactory sslContextFactory,
      HostnameVerifier hostnameVerifier,
      boolean disableRequestBuffering) {
    super();
    this.sslContextFactory = sslContextFactory;
    this.hostnameVerifier = hostnameVerifier;
    this.disableRequestBuffering = disableRequestBuffering;
  }

  @Override
  public Response execute(Request request, Options options) throws IOException {
    HttpURLConnection connection = convertAndSend(request, options);
    return convertResponse(connection, request);
  }

  Response convertResponse(HttpURLConnection connection, Request request) throws IOException {
    int status = connection.getResponseCode();
    String reason = connection.getResponseMessage();

    if (status < 0) {
      throw new IOException(
          format(
              "Invalid status(%s) executing %s %s",