diff --git a/sources/src/main/java/io/akarin/server/mixin/core/OptimisticNetworkManager.java b/sources/src/main/java/io/akarin/server/mixin/core/OptimisticNetworkManager.java index 743158e3d..cc8344182 100644 --- a/sources/src/main/java/io/akarin/server/mixin/core/OptimisticNetworkManager.java +++ b/sources/src/main/java/io/akarin/server/mixin/core/OptimisticNetworkManager.java @@ -28,7 +28,7 @@ public class OptimisticNetworkManager { @Shadow private Queue getPacketQueue() { return null; } @Shadow private void dispatchPacket(Packet packet, GenericFutureListener>[] genericFutureListeners) {} - private static final Predicate IS_CHUNK_READY = new Predicate() { + private static final Predicate IS_CHUNK_NOT_READY = new Predicate() { @Override public boolean apply(QueuedPacket item) { Packet packet = item.getPacket(); @@ -48,7 +48,7 @@ public class OptimisticNetworkManager { this.j.readLock().lock(); try { while (!this.i.isEmpty()) { - NetworkManager.QueuedPacket packet = ((CheckedConcurrentLinkedQueue) getPacketQueue()).poll(IS_CHUNK_READY, SIGNAL_PACKET); + NetworkManager.QueuedPacket packet = ((CheckedConcurrentLinkedQueue) getPacketQueue()).poll(IS_CHUNK_NOT_READY, SIGNAL_PACKET); if (packet != null) { // Fix NPE (Spigot bug caused by handleDisconnection()) if (packet == SIGNAL_PACKET) {