com.squareup.okhttp.internal.http

Class SpdyTransport

java.lang.Object

com.squareup.okhttp.internal.http.SpdyTransport

public final class SpdyTransport
extends Object

Constructor Summary

Constructors

Constructor and Description
SpdyTransport(HttpEngine httpEngine, SpdyConnection spdyConnection)

Method Summary

Modifier and Type	Method and Description
OutputStream	createRequestBody() Returns an output stream where the request body can be written.
void	flushRequest() Flush the request body to the underlying socket.
InputStream	getTransferStream(CacheRequest cacheRequest)
boolean	makeReusable(boolean streamCanceled, OutputStream requestBodyOut, InputStream responseBodyIn) Returns true if the underlying connection can be recycled.
ResponseHeaders	readResponseHeaders() Read response headers and update the cookie manager.
void	writeRequestBody(com.squareup.okhttp.internal.http.RetryableOutputStream requestBody) Sends the request body returned by createRequestBody() to the remote peer.
void	writeRequestHeaders() This should update the HTTP engine's sentRequestMillis field.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpdyTransport

public SpdyTransport(HttpEngine httpEngine,
                     SpdyConnection spdyConnection)

Method Detail

createRequestBody

public OutputStream createRequestBody()
                               throws IOException

Returns an output stream where the request body can be written. The returned stream will of one of two types:

• Direct. Bytes are written to the socket and forgotten. This is most efficient, particularly for large request bodies. The returned stream may be buffered; the caller must call flushRequest() before reading the response.
• Buffered. Bytes are written to an in memory buffer, and must be explicitly flushed with a call to writeRequestBody(com.squareup.okhttp.internal.http.RetryableOutputStream). This allows HTTP authorization (401, 407) responses to be retransmitted transparently.

Throws:

IOException

writeRequestHeaders

public void writeRequestHeaders()
                         throws IOException

This should update the HTTP engine's sentRequestMillis field.

Throws:

IOException

writeRequestBody

public void writeRequestBody(com.squareup.okhttp.internal.http.RetryableOutputStream requestBody)
                      throws IOException

Sends the request body returned by createRequestBody() to the remote peer.

Throws:

IOException

flushRequest

public void flushRequest()
                  throws IOException

Flush the request body to the underlying socket.

Throws:

IOException

readResponseHeaders

public ResponseHeaders readResponseHeaders()
                                    throws IOException

Read response headers and update the cookie manager.

Throws:

IOException

getTransferStream

public InputStream getTransferStream(CacheRequest cacheRequest)
                              throws IOException

Throws:

IOException

makeReusable

public boolean makeReusable(boolean streamCanceled,
                            OutputStream requestBodyOut,
                            InputStream responseBodyIn)

Returns true if the underlying connection can be recycled.