public class ChunkedInputStream extends InputStream implements Hurryable
ChunkedInputStreamprovides a stream for reading a body of a http message that can be sent as a series of chunks, each with its own size indicator. Optionally the last chunk can be followed by trailers containing entity-header fields.
ChunkedInputStream is also
Hurryable so it can be hurried to the end of the stream if the
bytes are available on the underlying stream.
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns the number of bytes that can be read from this input stream without blocking.
Close the stream by either returning the connection to the keep alive cache or closing the underlying stream.
Hurry the input stream by reading everything from the underlying stream.
See the general contract of the
Reads bytes from this stream into the specified byte array, starting at the given offset.
public ChunkedInputStream(InputStream in, HttpClient hc, MessageHeader responses) throws IOException
ChunkedInputStreamand saves its arguments, for later use.
in- the underlying input stream.
hc- the HttpClient
responses- the MessageHeader that should be populated with optional trailers.
public int available() throws IOException
public void close() throws IOException
If the chunked response hasn't been completely read we try to "hurry" to the end of the response. If this is possible (without blocking) then the connection can be returned to the keep alive cache.
public boolean hurry()
Note that if an error has occured or we can't get to last chunk without blocking then this stream can't be hurried and should be closed.
public int read() throws IOException
public int read(byte b, int off, int len) throws IOException
b- destination buffer.
off- offset at which to start storing bytes.
len- maximum number of bytes to read.
-1if the end of the stream has been reached.
IOException- if an I/O error occurs.