diff --git a/src/main/java/net/raphimc/viaproxy/proxy/client2proxy/passthrough/LegacyPassthroughInitialHandler.java b/src/main/java/net/raphimc/viaproxy/proxy/client2proxy/passthrough/LegacyPassthroughInitialHandler.java index ecea74e..85002c9 100644 --- a/src/main/java/net/raphimc/viaproxy/proxy/client2proxy/passthrough/LegacyPassthroughInitialHandler.java +++ b/src/main/java/net/raphimc/viaproxy/proxy/client2proxy/passthrough/LegacyPassthroughInitialHandler.java @@ -46,9 +46,10 @@ public class LegacyPassthroughInitialHandler extends SimpleChannelInboundHandler final PassthroughClient2ProxyChannelInitializer channelInitializer = new PassthroughClient2ProxyChannelInitializer(handlerSupplier); ctx.channel().pipeline().addLast(channelInitializer); ctx.channel().pipeline().fireChannelActive(); + ctx.pipeline().fireChannelRead(msg.retain()); + } else { + ctx.fireChannelRead(msg.retain()); } - - ctx.pipeline().fireChannelRead(msg.retain()); } @Override