@Contract(threading=SAFE) public final class SharedInputBuffer extends ExpandableBuffer implements ContentInputBuffer
ExpandableBuffer.Mode
Constructor and Description |
---|
SharedInputBuffer(int bufferSize) |
SharedInputBuffer(ReentrantLock lock,
int initialBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
int |
capacity()
Returns available capacity of this buffer.
|
int |
fill(ByteBuffer src) |
boolean |
hasData()
Determines if the buffer contains data.
|
boolean |
isEndStream() |
int |
length()
Returns the length of this buffer.
|
void |
markEndStream() |
int |
read()
Reads one byte from this buffer.
|
int |
read(byte[] b,
int off,
int len)
Reads up to
len bytes of data from this buffer into
an array of bytes. |
void |
reset() |
void |
updateCapacity(CapacityChannel capacityChannel) |
buffer, clear, ensureAdjustedCapacity, ensureCapacity, expand, mode, setInputMode, setOutputMode, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
length, reset
public SharedInputBuffer(ReentrantLock lock, int initialBufferSize)
public SharedInputBuffer(int bufferSize)
public int fill(ByteBuffer src)
public void updateCapacity(CapacityChannel capacityChannel) throws IOException
IOException
public int read() throws IOException
ContentInputBuffer
-1
if the end of content stream has been reached.read
in interface ContentInputBuffer
IOException
public int read(byte[] b, int off, int len) throws IOException
ContentInputBuffer
len
bytes of data from this buffer into
an array of bytes. The exact number of bytes read depends how many bytes
are stored in the buffer.
If off
is negative, or len
is negative, or
off+len
is greater than the length of the array
b
, this method can throw a runtime exception. The exact type
of runtime exception thrown by this method depends on implementation.
This method returns -1
if the end of content stream has been
reached.
read
in interface ContentInputBuffer
b
- the buffer into which the data is read.off
- the start offset in array b
at which the data is written.len
- the maximum number of bytes to read.-1
if there is no more data because the end of
the stream has been reached.IOException
- if an I/O error occurs.public void markEndStream()
public boolean hasData()
ExpandableBuffer
Sets the mode to output.
hasData
in class ExpandableBuffer
true
if there is data in the buffer,
false
otherwise.public int capacity()
ExpandableBuffer
capacity
in class ExpandableBuffer
public int length()
ExpandableBuffer
Sets the mode to output.
length
in class ExpandableBuffer
public void abort()
public void reset()
public boolean isEndStream()
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.