public interface ProtocolCodec
Modifier and Type | Interface and Description |
---|---|
static class |
ProtocolCodec.BufferState |
Modifier and Type | Method and Description |
---|---|
ProtocolCodec.BufferState |
flush()
Attempts to complete the previous write which did not complete.
|
boolean |
full()
Is the codec's buffer full?
|
long |
getLastReadSize() |
long |
getLastWriteSize() |
int |
getReadBufferSize() |
long |
getReadCounter() |
int |
getWriteBufferSize() |
long |
getWriteCounter() |
Object |
read()
Non-blocking channel based decoding.
|
void |
setTransport(Transport transport) |
void |
unread(byte[] buffer)
Pushes back a buffer as being unread.
|
ProtocolCodec.BufferState |
write(Object value)
Non-blocking channel based encoding.
|
void setTransport(Transport transport)
Object read() throws IOException
IOException
void unread(byte[] buffer)
buffer
- long getReadCounter()
long getLastReadSize()
int getReadBufferSize()
int getWriteBufferSize()
ProtocolCodec.BufferState write(Object value) throws IOException
IOException
ProtocolCodec.BufferState flush() throws IOException
IOException
boolean full()
long getWriteCounter()
long getLastWriteSize()
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.