package chat.server.netty; import java.util.List; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToMessageEncoder; import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame; public class ByteBufToWebSocketFrameEncoder extends MessageToMessageEncoder { @Override protected void encode(ChannelHandlerContext chc, ByteBuf bb, List out) throws Exception { // convert the ByteBuf to a WebSocketFrame BinaryWebSocketFrame result = new BinaryWebSocketFrame(); result.content().writeBytes(bb); out.add(result); } }