Fix Forge

This commit is contained in:
s809
2024-03-18 21:37:58 +05:00
parent e008eb8a13
commit af2f0e8582
3 changed files with 4 additions and 6 deletions
@@ -11,7 +11,6 @@ import com.seibel.distanthorizons.core.network.protocol.plugin.PluginMessageEnco
import com.seibel.distanthorizons.core.wrapperInterfaces.misc.IPluginPacketSender;
import com.seibel.distanthorizons.core.wrapperInterfaces.misc.IServerPlayerWrapper;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.PooledByteBufAllocator;
import org.apache.logging.log4j.LogManager;
import org.jetbrains.annotations.Nullable;
@@ -73,9 +72,7 @@ public class PluginChannelHandler extends NetworkEventSource<PluginChannelMessag
}
public void sendMessage(@Nullable IServerPlayerWrapper serverPlayer, PluginChannelMessage message)
{
ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();
this.messageEncoder.encode(message, buffer);
this.packetSender.sendPluginPacket(serverPlayer, buffer);
this.packetSender.sendPluginPacket(serverPlayer, buffer -> this.messageEncoder.encode(message, buffer));
}
@Override
@@ -26,7 +26,6 @@ import com.seibel.distanthorizons.core.level.DhClientLevel;
import com.seibel.distanthorizons.core.level.IDhLevel;
import com.seibel.distanthorizons.core.multiplayer.client.ClientNetworkState;
import com.seibel.distanthorizons.core.network.netty.NettyClient;
import com.seibel.distanthorizons.core.network.plugin.PluginChannelHandler;
import com.seibel.distanthorizons.core.util.ThreadUtil;
import com.seibel.distanthorizons.core.util.objects.EventLoop;
import com.seibel.distanthorizons.core.wrapperInterfaces.minecraft.IMinecraftClientWrapper;
@@ -4,8 +4,10 @@ import com.seibel.distanthorizons.coreapi.interfaces.dependencyInjection.IBindab
import io.netty.buffer.ByteBuf;
import org.jetbrains.annotations.Nullable;
import java.util.function.Consumer;
public interface IPluginPacketSender extends IBindable
{
void sendPluginPacket(@Nullable IServerPlayerWrapper serverPlayer, ByteBuf buffer);
void sendPluginPacket(@Nullable IServerPlayerWrapper serverPlayer, Consumer<ByteBuf> encoder);
}