| Modifier and Type | Class and Description |
|---|---|
| pack-priv class |
| Modifier and Type | Field and Description |
|---|---|
| private boolean | |
| private NIOInputStream | |
| private static final ThreadLocal | |
| private boolean | |
| private ReadHandler | |
| private final HttpServletRequestImpl |
| Access | Constructor and Description |
|---|---|
| protected |
| Modifier and Type | Method and Description |
|---|---|
| public int | available()
Overrides java. Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected. |
| public void | close()
Overrides java. Implements java. Close the stream Since we re-cycle, we can't allow the call to super.close() which would permanently disable us. |
| public void | |
| public boolean | isFinished()
Implements abstract jakarta. Returns true when all the data from the stream has been read else it returns false. |
| public boolean | isReady()
Implements abstract jakarta. Returns |
| public void | mark(final int readlimit)
Overrides java. Marks the current position in this input stream. |
| public boolean | markSupported()
Overrides java. Tests if this input stream supports the |
| public int | read()
Implements abstract java. Reads the next byte of data from the input stream. |
| public int | read(final byte[] b)
Overrides java. Reads some number of bytes from the input stream and stores them into
the buffer array |
| public int | read(final byte[] b, final int off, final int len)
Overrides java. Reads up to |
| pack-priv void | |
| public void | reset()
Overrides java. Repositions this stream to the position at the time the
|
| public void | setReadListener(final ReadListener readListener)
Implements abstract jakarta. Instructs the |
| public long | skip(final long n)
Overrides java. Skips over and discards |
| hasSetReadListener | back to summary |
|---|---|
| private boolean hasSetReadListener | |
| inputStream | back to summary |
|---|---|
| private NIOInputStream inputStream | |
| IS_READY_SCOPE | back to summary |
|---|---|
| private static final ThreadLocal<Boolean> IS_READY_SCOPE | |
| prevIsReady | back to summary |
|---|---|
| private boolean prevIsReady | |
| readHandler | back to summary |
|---|---|
| private ReadHandler readHandler | |
| servletRequest | back to summary |
|---|---|
| private final HttpServletRequestImpl servletRequest | |
| ServletInputStreamImpl | back to summary |
|---|---|
| protected ServletInputStreamImpl(final HttpServletRequestImpl servletRequest) | |
| available | back to summary |
|---|---|
| public int available() throws IOException Overrides java. Doc from java. Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected. The read might be on the same thread or another thread. A single read or skip of this many bytes will not block, but may read or skip fewer bytes. Note that while some implementations of A subclass's implementation of this method may choose to throw an
| |
| close | back to summary |
|---|---|
| public void close() throws IOException Overrides java. Implements java. Close the stream Since we re-cycle, we can't allow the call to super.close() which would permanently disable us.
| |
| initialize | back to summary |
|---|---|
| public void initialize() throws IOException | |
| isFinished | back to summary |
|---|---|
| public boolean isFinished() Implements abstract jakarta. Doc from jakarta. Returns true when all the data from the stream has been read else it returns false.
| |
| isReady | back to summary |
|---|---|
| public boolean isReady() Implements abstract jakarta. Doc from jakarta. Returns
If this method returns
| |
| mark | back to summary |
|---|---|
| public void mark(final int readlimit) Overrides java. Doc from java. Marks the current position in this input stream. A subsequent call to
the The The general contract of Marking a closed stream should not have any effect on the stream.
| |
| markSupported | back to summary |
|---|---|
| public boolean markSupported() Overrides java. Doc from java. Tests if this input stream supports the
| |
| read | back to summary |
|---|---|
| public int read() throws IOException Implements abstract java. Doc from java. Reads the next byte of data from the input stream. The value byte is
returned as an
| |
| read | back to summary |
|---|---|
| public int read(final byte[] b) throws IOException Overrides java. Doc from java. Reads some number of bytes from the input stream and stores them into
the buffer array If the length of The first byte read is stored into element
| |
| read | back to summary |
|---|---|
| public int read(final byte[] b, final int off, final int len) throws IOException Overrides java. Doc from java. Reads up to This method blocks until input data is available, end of file is detected, or an exception is thrown. If The first byte read is stored into element In every case, elements
| |
| recycle | back to summary |
|---|---|
| pack-priv void recycle() | |
| reset | back to summary |
|---|---|
| public void reset() throws IOException Overrides java. Doc from java. Repositions this stream to the position at the time the
The general contract of
| |
| setReadListener | back to summary |
|---|---|
| public void setReadListener(final ReadListener readListener) Implements abstract jakarta. Doc from jakarta. Instructs the
| |
| skip | back to summary |
|---|---|
| public long skip(final long n) throws IOException Overrides java. Doc from java. Skips over and discards
| |
| Modifier and Type | Field and Description |
|---|---|
| private ReadListener |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| private void | |
| private void | |
| public void | onAllDataRead()
Implements org. Invoked when all data for the current request has been read. |
| public void | onDataAvailable()
Implements org. Invoked when data is available to be read without blocking. |
| public void | onError(final Throwable t)
Implements org. Invoked when an error occurs processing the request asynchronously. |
| readListener | back to summary |
|---|---|
| private ReadListener readListener | |
| ReadHandlerImpl | back to summary |
|---|---|
| private ReadHandlerImpl(ReadListener listener) | |
| invokeAllDataReadCallback | back to summary |
|---|---|
| private void invokeAllDataReadCallback() | |
| invokeReadPossibleCallback | back to summary |
|---|---|
| private void invokeReadPossibleCallback() | |
| onAllDataRead | back to summary |
|---|---|
| public void onAllDataRead() throws Exception Implements org. Doc from org. Invoked when all data for the current request has been read.
| |
| onDataAvailable | back to summary |
|---|---|
| public void onDataAvailable() throws Exception Implements org. Doc from org. Invoked when data is available to be read without blocking. Data must be consumed by the handler implementation before re-registering.
| |
| onError | back to summary |
|---|---|
| public void onError(final Throwable t) Implements org. Doc from org. Invoked when an error occurs processing the request asynchronously.
| |