public abstract class AbstractNioBufferReactorNettyCodec<P> extends Object implements ReactorNettyCodec<P>
ReactorNettyCodec implementations that need
to work with NIO ByteBuffers.| Constructor and Description |
|---|
AbstractNioBufferReactorNettyCodec() |
| Modifier and Type | Method and Description |
|---|---|
Collection<Message<P>> |
decode(io.netty.buffer.ByteBuf inputBuffer)
Decode the input
ByteBuf into one or more Messages. |
protected abstract List<Message<P>> |
decodeInternal(ByteBuffer nioBuffer) |
void |
encode(Message<P> message,
io.netty.buffer.ByteBuf outputBuffer)
Encode the given
Message to the output ByteBuf. |
protected abstract ByteBuffer |
encodeInternal(Message<P> message) |
public 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 List<Message<P>> decodeInternal(ByteBuffer nioBuffer)
protected abstract ByteBuffer encodeInternal(Message<P> message)