public abstract class AbstractNioBufferReactorNettyCodec<P> extends java.lang.Object implements ReactorNettyCodec<P>
ReactorNettyCodec implementations that need
to work with NIO ByteBuffers.| Constructor and Description |
|---|
AbstractNioBufferReactorNettyCodec() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Collection<Message<P>> |
decode(io.netty.buffer.ByteBuf inputBuffer)
Decode the input
ByteBuf into one or more Messages. |
protected abstract java.util.List<Message<P>> |
decodeInternal(java.nio.ByteBuffer nioBuffer) |
void |
encode(Message<P> message,
io.netty.buffer.ByteBuf outputBuffer)
Encode the given
Message to the output ByteBuf. |
protected abstract java.nio.ByteBuffer |
encodeInternal(Message<P> message) |
public java.util.Collection<Message<P>> decode(io.netty.buffer.ByteBuf inputBuffer)
ReactorNettyCodecByteBuf into one or more Messages.decode in interface ReactorNettyCodec<P>inputBuffer - the input buffer to decode frompublic void encode(Message<P> message, io.netty.buffer.ByteBuf outputBuffer)
ReactorNettyCodecMessage to the output ByteBuf.encode in interface ReactorNettyCodec<P>message - the message the encodeoutputBuffer - the buffer to write toprotected abstract java.util.List<Message<P>> decodeInternal(java.nio.ByteBuffer nioBuffer)