com.squareup.okhttp.internal.http.HttpEngine#readResponse ( )源码实例Demo

下面列出了com.squareup.okhttp.internal.http.HttpEngine#readResponse ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： L.TileLayer.Cordova 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码2 项目： IoTgo_Android_App 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码3 项目： bluemix-parking-meter 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码4 项目： reader 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码5 项目： reader 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码6 项目： cordova-amazon-fireos 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码7 项目： phonegapbootcampsite 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码8 项目： CordovaYoutubeVideoPlayer 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码9 项目： wildfly-samples 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

源代码10 项目： crosswalk-cordova-android 文件： Job.java

private Response execute() throws IOException {
  Connection connection = null;
  Response redirectedBy = null;

  while (true) {
    HttpEngine engine = newEngine(connection);

    Request.Body body = request.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType == null) throw new IllegalStateException("contentType == null");
      if (engine.getRequestHeaders().getContentType() == null) {
        engine.getRequestHeaders().setContentType(contentType.toString());
      }
    }

    engine.sendRequest();

    if (body != null) {
      body.writeTo(engine.getRequestBody());
    }

    engine.readResponse();

    int responseCode = engine.getResponseCode();
    Dispatcher.RealResponseBody responseBody = new Dispatcher.RealResponseBody(
        engine.getResponseHeaders(), engine.getResponseBody());

    Response response = new Response.Builder(request, responseCode)
        .rawHeaders(engine.getResponseHeaders().getHeaders())
        .body(responseBody)
        .redirectedBy(redirectedBy)
        .build();

    Request redirect = processResponse(engine, response);

    if (redirect == null) {
      engine.automaticallyReleaseConnectionToPool();
      return response;
    }

    // TODO: fail if too many redirects
    // TODO: fail if not following redirects
    // TODO: release engine

    connection = sameConnection(request, redirect) ? engine.getConnection() : null;
    redirectedBy = response;
    request = redirect;
  }
}

方法所在类

com.squareup.okhttp.internal.http.HttpEngine