src/protocolsupport/protocol/pipeline/common/VarIntFrameEncoder.java

package protocolsupport.protocol.pipeline.common;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import protocolsupport.protocol.pipeline.IPacketPrepender;
import protocolsupport.utils.netty.ChannelUtils;

public class VarIntFrameEncoder implements IPacketPrepender {

	@Override
	public void prepend(ChannelHandlerContext ctx, ByteBuf input, ByteBuf output) throws Exception {
		int readableBytes = input.readableBytes();
		output.ensureWritable(readableBytes + 3);
		ChannelUtils.writeVarInt(output, readableBytes);
		output.writeBytes(input);
	}

}