public abstract class AbstractOioMessageChannel extends AbstractOioChannel
AbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
private java.util.List<java.lang.Object> |
readBuf |
readPending, SO_TIMEOUT| Modifier | Constructor and Description |
|---|---|
protected |
AbstractOioMessageChannel(Channel parent) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doRead() |
protected abstract int |
doReadMessages(java.util.List<java.lang.Object> msgs)
Read messages into the given array and return the amount which was read.
|
clearReadPending, doBeginRead, doConnect, isCompatible, isReadPending, newUnsafe, setReadPendingalloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitattr, hasAttrprotected AbstractOioMessageChannel(Channel parent)
protected void doRead()
doRead in class AbstractOioChannelprotected abstract int doReadMessages(java.util.List<java.lang.Object> msgs)
throws java.lang.Exception
java.lang.Exception