|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.http.nio.util.ExpandableBuffer org.apache.http.impl.nio.reactor.SessionInputBufferImpl
public class SessionInputBufferImpl
Default implementation of SessionInputBuffer
based on
the ExpandableBuffer
class.
Field Summary |
---|
Fields inherited from class org.apache.http.nio.util.ExpandableBuffer |
---|
buffer, INPUT_MODE, OUTPUT_MODE |
Constructor Summary | |
---|---|
SessionInputBufferImpl(int bufferSize)
Creates SessionInputBufferImpl instance. |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize)
Creates SessionInputBufferImpl instance. |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
ByteBufferAllocator allocator,
HttpParams params)
Deprecated. (4.3) use SessionInputBufferImpl(int, int, CharsetDecoder,
ByteBufferAllocator) |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
Charset charset)
Creates SessionInputBufferImpl instance. |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
CharsetDecoder charDecoder,
ByteBufferAllocator allocator)
Creates SessionInputBufferImpl instance. |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
HttpParams params)
Deprecated. (4.3) use SessionInputBufferImpl(int, int, Charset) |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
MessageConstraints constraints,
Charset charset)
Creates SessionInputBufferImpl instance. |
|
SessionInputBufferImpl(int bufferSize,
int lineBufferSize,
MessageConstraints constraints,
CharsetDecoder charDecoder,
ByteBufferAllocator allocator)
Creates SessionInputBufferImpl instance. |
Method Summary | |
---|---|
void |
clear()
Clears buffer. |
int |
fill(ReadableByteChannel channel)
Makes an attempt to fill the buffer with data from the given ReadableByteChannel . |
int |
read()
Reads one byte from the buffer. |
int |
read(ByteBuffer dst)
Reads a sequence of bytes from this buffer into the destination buffer. |
int |
read(ByteBuffer dst,
int maxLen)
Reads a sequence of bytes from this buffer into the destination buffer, up to the given maximum limit. |
int |
read(WritableByteChannel dst)
Reads a sequence of bytes from this buffer into the destination channel. |
int |
read(WritableByteChannel dst,
int maxLen)
Reads a sequence of bytes from this buffer into the destination channel, up to the given maximum limit. |
String |
readLine(boolean endOfStream)
Attempts to transfer a complete line of characters up to a line delimiter from this buffer to a newly created string. |
boolean |
readLine(CharArrayBuffer lineBuffer,
boolean endOfStream)
Attempts to transfer a complete line of characters up to a line delimiter from this buffer to the destination buffer. |
Methods inherited from class org.apache.http.nio.util.ExpandableBuffer |
---|
available, capacity, ensureCapacity, expand, getMode, hasData, length, setInputMode, setOutputMode, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.http.nio.reactor.SessionInputBuffer |
---|
hasData, length |
Constructor Detail |
---|
public SessionInputBufferImpl(int bufferSize, int lineBufferSize, MessageConstraints constraints, CharsetDecoder charDecoder, ByteBufferAllocator allocator)
bufferSize
- input buffer size.lineBufferSize
- buffer size for line operations. Has effect only if
charDecoder
is not null
.charDecoder
- CharDecoder to be used for decoding HTTP protocol elements.
If null
simple type cast will be used for byte to char conversion.constraints
- Message constraints. If null
MessageConstraints.DEFAULT
will be used.allocator
- memory allocator.
If null
HeapByteBufferAllocator.INSTANCE
will be used.public SessionInputBufferImpl(int bufferSize, int lineBufferSize, CharsetDecoder charDecoder, ByteBufferAllocator allocator)
bufferSize
- input buffer size.lineBufferSize
- buffer size for line operations. Has effect only if
charDecoder
is not null
.charDecoder
- CharDecoder to be used for decoding HTTP protocol elements.
If null
simple type cast will be used for byte to char conversion.allocator
- memory allocator.
If null
HeapByteBufferAllocator.INSTANCE
will be used.@Deprecated public SessionInputBufferImpl(int bufferSize, int lineBufferSize, ByteBufferAllocator allocator, HttpParams params)
SessionInputBufferImpl(int, int, CharsetDecoder,
ByteBufferAllocator)
@Deprecated public SessionInputBufferImpl(int bufferSize, int lineBufferSize, HttpParams params)
SessionInputBufferImpl(int, int, Charset)
public SessionInputBufferImpl(int bufferSize, int lineBufferSize, Charset charset)
bufferSize
- input buffer size.lineBufferSize
- buffer size for line operations. Has effect only if
charset
is not null
.charset
- Charset to be used for decoding HTTP protocol elements.
If null
simple type cast will be used for byte to char conversion.public SessionInputBufferImpl(int bufferSize, int lineBufferSize, MessageConstraints constraints, Charset charset)
bufferSize
- input buffer size.lineBufferSize
- buffer size for line operations. Has effect only if
charset
is not null
.charset
- Charset to be used for decoding HTTP protocol elements.
If null
simple type cast will be used for byte to char conversion.constraints
- Message constraints. If null
MessageConstraints.DEFAULT
will be used.public SessionInputBufferImpl(int bufferSize, int lineBufferSize)
bufferSize
- input buffer size.lineBufferSize
- buffer size for line operations.public SessionInputBufferImpl(int bufferSize)
bufferSize
- input buffer size.Method Detail |
---|
public int fill(ReadableByteChannel channel) throws IOException
SessionInputBuffer
ReadableByteChannel
.
fill
in interface SessionInputBuffer
channel
- the source channel
-1
if the
channel has reached end-of-stream.
IOException
- in case of an I/O error.public int read()
SessionInputBuffer
read
in interface SessionInputBuffer
public int read(ByteBuffer dst, int maxLen)
SessionInputBuffer
maxLen
value.
read
in interface SessionInputBuffer
dst
- the destination buffer.maxLen
- the maximum number of bytes to be read.
public int read(ByteBuffer dst)
SessionInputBuffer
read
in interface SessionInputBuffer
dst
- the destination buffer.
public int read(WritableByteChannel dst, int maxLen) throws IOException
SessionInputBuffer
maxLen
value.
read
in interface SessionInputBuffer
dst
- the destination channel.maxLen
- the maximum number of bytes to be read.
IOException
- in case of an I/O error.public int read(WritableByteChannel dst) throws IOException
SessionInputBuffer
read
in interface SessionInputBuffer
dst
- the destination channel.
IOException
- in case of an I/O error.public boolean readLine(CharArrayBuffer lineBuffer, boolean endOfStream) throws CharacterCodingException
SessionInputBuffer
true
. The line
delimiter itself is discarded. If a complete line is not available in
the buffer, this method returns false
without transferring
anything to the destination buffer. If endOfStream
parameter
is set to true
this method assumes the end of stream has
been reached and the content currently stored in the buffer should be
treated as a complete line.
The choice of a char encoding and line delimiter sequence is up to the specific implementations of this interface.
readLine
in interface SessionInputBuffer
lineBuffer
- the destination buffer.endOfStream
- end of stream flag
true
if a sequence of chars representing a complete
line has been transferred to the destination buffer, false
otherwise.
CharacterCodingException
- in case a character encoding or decoding
error occurs.public String readLine(boolean endOfStream) throws CharacterCodingException
SessionInputBuffer
null
. If endOfStream
parameter
is set to true
this method assumes the end of stream has
been reached and the content currently stored in the buffer should be
treated as a complete line.
The choice of a char encoding and line delimiter sequence is up to the specific implementations of this interface.
readLine
in interface SessionInputBuffer
endOfStream
- end of stream flag
null
otherwise.
CharacterCodingException
- in case a character encoding or decoding
error occurs.public void clear()
ExpandableBuffer
clear
in class ExpandableBuffer
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |