package net.minecraft.network;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class MonitorFrameDecoder extends ChannelInboundHandlerAdapter {
	private final BandwidthDebugMonitor monitor;

	public MonitorFrameDecoder(BandwidthDebugMonitor monitor) {
		this.monitor = monitor;
	}

	@Override
	public void channelRead(ChannelHandlerContext channelHandlerContext, Object object) {
		if (object instanceof ByteBuf byteBuf) {
			this.monitor.onReceive(byteBuf.readableBytes());
		}

		channelHandlerContext.fireChannelRead(object);
	}
}