diff --git a/core/src/main/java/org/geysermc/geyser/network/netty/LocalSession.java b/core/src/main/java/org/geysermc/geyser/network/netty/LocalSession.java index 5651fefcd..d9e450c62 100644 --- a/core/src/main/java/org/geysermc/geyser/network/netty/LocalSession.java +++ b/core/src/main/java/org/geysermc/geyser/network/netty/LocalSession.java @@ -155,9 +155,7 @@ public final class LocalSession extends TcpSession { HAProxyProtocolVersion.V2, HAProxyCommand.PROXY, proxiedProtocol, clientAddress.getAddress().getHostAddress(), remoteAddress.getAddress().getHostAddress(), clientAddress.getPort(), remoteAddress.getPort() - )).addListener(future -> { - channel.pipeline().remove("proxy-protocol-encoder"); - }); + )).addListener(future -> channel.pipeline().remove("proxy-protocol-encoder")); } /**