com.squareup.okhttp.internal.http

Class Http2xStream

java.lang.Object

com.squareup.okhttp.internal.http.Http2xStream

All Implemented Interfaces:

HttpStream

public final class Http2xStream
extends Object
implements HttpStream

An HTTP stream for HTTP/2 and SPDY.

Field Summary

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

DISCARD_STREAM_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor and Description
Http2xStream(StreamAllocation streamAllocation, FramedConnection framedConnection)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel this stream.
okio.Sink	createRequestBody(Request request, long contentLength) Returns an output stream where the request body can be streamed.
void	finishRequest() Flush the request to the underlying socket.
static List<Header>	http2HeadersList(Request request)
ResponseBody	openResponseBody(Response response) Returns a stream that reads the response body.
static Response.Builder	readHttp2HeadersList(List<Header> headerBlock) Returns headers for a name value block containing an HTTP/2 response.
Response.Builder	readResponseHeaders() Read and return response headers.
static Response.Builder	readSpdy3HeadersList(List<Header> headerBlock) Returns headers for a name value block containing a SPDY response.
void	setHttpEngine(HttpEngine httpEngine)
static List<Header>	spdy3HeadersList(Request request) Returns a list of alternating names and values containing a SPDY request.
void	writeRequestBody(RetryableSink requestBody) Sends the request body returned by HttpStream.createRequestBody(com.squareup.okhttp.Request, long) to the remote peer.
void	writeRequestHeaders(Request request) 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

Http2xStream

public Http2xStream(StreamAllocation streamAllocation,
                    FramedConnection framedConnection)

Method Detail

setHttpEngine

public void setHttpEngine(HttpEngine httpEngine)

Specified by:

setHttpEngine in interface HttpStream

createRequestBody

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

Description copied from interface: HttpStream

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

Specified by:

createRequestBody in interface HttpStream

Throws:

IOException

writeRequestHeaders

public void writeRequestHeaders(Request request)
                         throws IOException

Description copied from interface: HttpStream

This should update the HTTP engine's sentRequestMillis field.

Specified by:

writeRequestHeaders in interface HttpStream

Throws:

IOException

writeRequestBody

public void writeRequestBody(RetryableSink requestBody)
                      throws IOException

Description copied from interface: HttpStream

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

Specified by:

writeRequestBody in interface HttpStream

Throws:

IOException

finishRequest

public void finishRequest()
                   throws IOException

Description copied from interface: HttpStream

Flush the request to the underlying socket.

Specified by:

finishRequest in interface HttpStream

Throws:

IOException

readResponseHeaders

public Response.Builder readResponseHeaders()
                                     throws IOException

Description copied from interface: HttpStream

Read and return response headers.

Specified by:

readResponseHeaders in interface HttpStream

Throws:

IOException

spdy3HeadersList

public static List<Header> spdy3HeadersList(Request request)

Returns a list of alternating names and values containing a SPDY request. Names are all lowercase. No names are repeated. If any name has multiple values, they are concatenated using "\0" as a delimiter.

http2HeadersList

public static List<Header> http2HeadersList(Request request)

readSpdy3HeadersList

public static Response.Builder readSpdy3HeadersList(List<Header> headerBlock)
                                             throws IOException

Returns headers for a name value block containing a SPDY response.

Throws:

IOException

readHttp2HeadersList

public static Response.Builder readHttp2HeadersList(List<Header> headerBlock)
                                             throws IOException

Returns headers for a name value block containing an HTTP/2 response.

Throws:

IOException

openResponseBody

public ResponseBody openResponseBody(Response response)
                              throws IOException

Description copied from interface: HttpStream

Returns a stream that reads the response body.

Specified by:

openResponseBody in interface HttpStream

Throws:

IOException

cancel

public void cancel()

Description copied from interface: HttpStream

Cancel this stream. Resources held by this stream will be cleaned up, though not synchronously. That may happen later by the connection pool thread.

Specified by:

cancel in interface HttpStream