com.squareup.okhttp.internal.http

Class HttpTransport

java.lang.Object

com.squareup.okhttp.internal.http.HttpTransport

All Implemented Interfaces:

Transport

public final class HttpTransport
extends Object
implements Transport

Field Summary

Fields inherited from interface com.squareup.okhttp.internal.http.Transport

DISCARD_STREAM_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor and Description
HttpTransport(HttpEngine httpEngine, HttpConnection httpConnection)

Method Summary

Modifier and Type	Method and Description
boolean	canReuseConnection() Returns true if the socket connection held by this transport can be reused for a follow-up exchange.
okio.Sink	createRequestBody(Request request, long contentLength) Returns an output stream where the request body can be streamed.
void	disconnect(HttpEngine engine)
void	finishRequest() Flush the request to the underlying socket.
ResponseBody	openResponseBody(Response response) Returns a stream that reads the response body.
Response.Builder	readResponseHeaders() Read and return response headers.
void	releaseConnectionOnIdle() Configures the response body to pool or close the socket connection when the response body is closed.
void	writeRequestBody(RetryableSink requestBody) Sends the request body returned by Transport.createRequestBody(com.squareup.okhttp.Request, long) to the remote peer.
void	writeRequestHeaders(Request request) Prepares the HTTP headers and sends them to the server.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpTransport

public HttpTransport(HttpEngine httpEngine,
                     HttpConnection httpConnection)

Method Detail

createRequestBody

public okio.Sink createRequestBody(Request request,
                                   long contentLength)
                            throws IOException

Description copied from interface: Transport

Returns an output stream where the request body can be streamed.

Specified by:

createRequestBody in interface Transport

Throws:

IOException

finishRequest

public void finishRequest()
                   throws IOException

Description copied from interface: Transport

Flush the request to the underlying socket.

Specified by:

finishRequest in interface Transport

Throws:

IOException

writeRequestBody

public void writeRequestBody(RetryableSink requestBody)
                      throws IOException

Description copied from interface: Transport

Sends the request body returned by Transport.createRequestBody(com.squareup.okhttp.Request, long) to the remote peer.

Specified by:

writeRequestBody in interface Transport

Throws:

IOException

writeRequestHeaders

public void writeRequestHeaders(Request request)
                         throws IOException

Prepares the HTTP headers and sends them to the server.

For streaming requests with a body, headers must be prepared before the output stream has been written to. Otherwise the body would need to be buffered!

For non-streaming requests with a body, headers must be prepared after the output stream has been written to and closed. This ensures that the Content-Length header field receives the proper value.

Specified by:

writeRequestHeaders in interface Transport

Throws:

IOException

readResponseHeaders

public Response.Builder readResponseHeaders()
                                     throws IOException

Description copied from interface: Transport

Read and return response headers.

Specified by:

readResponseHeaders in interface Transport

Throws:

IOException

releaseConnectionOnIdle

public void releaseConnectionOnIdle()
                             throws IOException

Description copied from interface: Transport

Configures the response body to pool or close the socket connection when the response body is closed.

Specified by:

releaseConnectionOnIdle in interface Transport

Throws:

IOException

canReuseConnection

public boolean canReuseConnection()

Description copied from interface: Transport

Returns true if the socket connection held by this transport can be reused for a follow-up exchange.

Specified by:

canReuseConnection in interface Transport

openResponseBody

public ResponseBody openResponseBody(Response response)
                              throws IOException

Description copied from interface: Transport

Returns a stream that reads the response body.

Specified by:

openResponseBody in interface Transport

Throws:

IOException

disconnect

public void disconnect(HttpEngine engine)
                throws IOException

Specified by:

disconnect in interface Transport

Throws:

IOException