fix

TexBlock · TexBlock · commit f56737dd1b29 · 2025-10-12T22:40:24.000+08:00
diff --git a/fabric-networking-api-v1/src/client/java/org/sinytra/fabric/networking_api/client/NeoClientCommonNetworking.java b/fabric-networking-api-v1/src/client/java/org/sinytra/fabric/networking_api/client/NeoClientCommonNetworking.java
@@ -17,19 +17,19 @@ public static void onRegisterPacket(ICommonPacketListener listener, Set<Resource
         ConnectionProtocol protocol = listener.protocol();
         List<ResourceLocation> listIds = List.copyOf(ids);
         if (protocol == ConnectionProtocol.CONFIGURATION) {
-            listener.getMainThreadEventLoop().execute(() -> C2SConfigurationChannelEvents.REGISTER.invoker().onChannelRegister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
+            listener.getPacketProcessor().scheduleIfPossible(() -> C2SConfigurationChannelEvents.REGISTER.invoker().onChannelRegister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
         } else if (protocol == ConnectionProtocol.PLAY) {
-            listener.getMainThreadEventLoop().execute(() -> C2SPlayChannelEvents.REGISTER.invoker().onChannelRegister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
+            listener.getPacketProcessor().scheduleIfPossible(() -> C2SPlayChannelEvents.REGISTER.invoker().onChannelRegister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
         }
     }
 
     public static void onUnregisterPacket(ICommonPacketListener listener, Set<ResourceLocation> ids) {
         ConnectionProtocol protocol = listener.protocol();
         List<ResourceLocation> listIds = List.copyOf(ids);
         if (protocol == ConnectionProtocol.CONFIGURATION) {
-            listener.getMainThreadEventLoop().execute(() -> C2SConfigurationChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
+            listener.getPacketProcessor().scheduleIfPossible(() -> C2SConfigurationChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
         } else if (protocol == ConnectionProtocol.PLAY) {
-            listener.getMainThreadEventLoop().execute(() -> C2SPlayChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
+            listener.getPacketProcessor().scheduleIfPossible(() -> C2SPlayChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -17,19 +17,19 @@ public static void onRegisterPacket(ICommonPacketListener listener, Set<Resource`
`17`	`17`	`ConnectionProtocol protocol = listener.protocol();`
`18`	`18`	`List<ResourceLocation> listIds = List.copyOf(ids);`
`19`	`19`	`if (protocol == ConnectionProtocol.CONFIGURATION) {`
`20`		`- listener.getMainThreadEventLoop().execute(() -> C2SConfigurationChannelEvents.REGISTER.invoker().onChannelRegister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
	`20`	`+ listener.getPacketProcessor().scheduleIfPossible(() -> C2SConfigurationChannelEvents.REGISTER.invoker().onChannelRegister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
`21`	`21`	`} else if (protocol == ConnectionProtocol.PLAY) {`
`22`		`- listener.getMainThreadEventLoop().execute(() -> C2SPlayChannelEvents.REGISTER.invoker().onChannelRegister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
	`22`	`+ listener.getPacketProcessor().scheduleIfPossible(() -> C2SPlayChannelEvents.REGISTER.invoker().onChannelRegister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
`23`	`23`	`}`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`public static void onUnregisterPacket(ICommonPacketListener listener, Set<ResourceLocation> ids) {`
`27`	`27`	`ConnectionProtocol protocol = listener.protocol();`
`28`	`28`	`List<ResourceLocation> listIds = List.copyOf(ids);`
`29`	`29`	`if (protocol == ConnectionProtocol.CONFIGURATION) {`
`30`		`- listener.getMainThreadEventLoop().execute(() -> C2SConfigurationChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
	`30`	`+ listener.getPacketProcessor().scheduleIfPossible(() -> C2SConfigurationChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientConfigurationPacketListenerImpl) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
`31`	`31`	`} else if (protocol == ConnectionProtocol.PLAY) {`
`32`		`- listener.getMainThreadEventLoop().execute(() -> C2SPlayChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
	`32`	`+ listener.getPacketProcessor().scheduleIfPossible(() -> C2SPlayChannelEvents.UNREGISTER.invoker().onChannelUnregister((ClientPacketListener) listener, new NeoClientPacketSender(listener.getConnection()), Minecraft.getInstance(), listIds));`
`33`	`33`	`}`
`34`	`34`	`}`
`35`	`35`	`}`