public interface ReactorNettyCodec<P>
Function and an encoding
BiConsumer to use with Reactor Netty.| Modifier and Type | Method and Description |
|---|---|
Collection<Message<P>> |
decode(io.netty.buffer.ByteBuf inputBuffer)
Decode the input
ByteBuf into one or more Messages. |
void |
encode(Message<P> message,
io.netty.buffer.ByteBuf outputBuffer)
Encode the given
Message to the output ByteBuf. |
Collection<Message<P>> decode(io.netty.buffer.ByteBuf inputBuffer)
ByteBuf into one or more Messages.inputBuffer - the input buffer to decode from