| java.lang.Object org.xsocket.connection.spi.IoQueue
IoQueue | final class IoQueue (Code) | | author: grro@xsocket.org |
Method Summary | |
public synchronized void | addFirst(ByteBuffer[] data) | public synchronized void | append(ByteBuffer data) append a byte buffer to this queue. | public synchronized void | append(ByteBuffer[] data) append a list of byte buffer to this queue. | public synchronized ByteBuffer[] | drain() | public synchronized int | getSize() | public synchronized boolean | isEmpty() |
addFirst | public synchronized void addFirst(ByteBuffer[] data)(Code) | | add the given ByteBuffer array into the head of the queue
Parameters: bufs - the list of ByteBuffer |
append | public synchronized void append(ByteBuffer data)(Code) | | append a byte buffer to this queue.
Parameters: data - the ByteBuffer to append |
append | public synchronized void append(ByteBuffer[] data)(Code) | | append a list of byte buffer to this queue. By adding a list,
the list becomes part of to the buffer, and should not be modified outside the buffer
to avoid side effects
Parameters: bufs - the list of ByteBuffer |
drain | public synchronized ByteBuffer[] drain()(Code) | | drain this queue
the contained ByteBuffer array or null |
getSize | public synchronized int getSize()(Code) | | return the current size
the current size |
isEmpty | public synchronized boolean isEmpty()(Code) | | returns true, if empty
true, if empty |
|
|