From f1f1d409c43a86a3a4b1ff23045d1b641cca7cf5 Mon Sep 17 00:00:00 2001 From: Sotr Date: Sat, 9 Jun 2018 16:08:45 +0800 Subject: [PATCH] [ci skip] Corrects name --- .../io/akarin/server/mixin/core/OptimisticNetworkManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {