public abstract class AbstractNioBufferReactorNettyCodec<P> extends Object implements ReactorNettyCodec<P>
ReactorNettyCodec
implementations that need
to work with NIO ByteBuffer
s.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 Message s. |
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)
ReactorNettyCodec
ByteBuf
into one or more Message
s.decode
in interface ReactorNettyCodec<P>
inputBuffer
- the input buffer to decode frompublic void encode(Message<P> message, io.netty.buffer.ByteBuf outputBuffer)
ReactorNettyCodec
Message
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)