fix: enqueue asnyc packet event after processing delay is zero

Author: Ingrim4

src/main/java/com/comphenix/protocol/async/AsyncFilterManager.java

@@ -413,6 +413,19 @@ private void signalPacketTransmission(PacketEvent packet, boolean onMainThread)
 
         // Only send if the packet is ready
         if (marker.decrementProcessingDelay() == 0) {
+
+            // Now, get the next non-cancelled listener
+            if (!marker.hasExpired()) {
+                for (; marker.getListenerTraversal().hasNext(); ) {
+                    AsyncListenerHandler handler = marker.getListenerTraversal().next().getListener();
+                    
+                    if (!handler.isCancelled()) {
+                        getProcessingQueue(packet).enqueue(packet, onMainThread);
+                        return;
+                    }
+                }
+            }
+
             PacketSendingQueue queue = getSendingQueue(packet, false);
 
             // No need to create a new queue if the player has logged out

src/main/java/com/comphenix/protocol/async/AsyncListenerHandler.java

@@ -632,18 +632,6 @@ private void processPacket(int workerID, PacketEvent packet, String methodName)
             filterManager.getErrorReporter().reportMinimal(listener.getPlugin(), methodName, e);
         }
 
-        // Now, get the next non-cancelled listener
-        if (!marker.hasExpired()) {
-            for (; marker.getListenerTraversal().hasNext(); ) {
-                AsyncListenerHandler handler = marker.getListenerTraversal().next().getListener();
-                
-                if (!handler.isCancelled()) {
-                    handler.enqueuePacket(packet);
-                    return;
-                }
-            }
-        }
-        
         // There are no more listeners - queue the packet for transmission
         filterManager.signalFreeProcessingSlot(packet);
 

src/main/java/com/comphenix/protocol/async/PacketProcessingQueue.java

@@ -131,20 +131,32 @@ public void signalBeginProcessing(boolean onMainThread) {
             if (holder != null) {
                 PacketEvent packet = holder.getEvent();
                 AsyncMarker marker = packet.getAsyncMarker();
-                Collection<PrioritizedListener<AsyncListenerHandler>> list = getListener(packet.getPacketType());
+                Iterator<PrioritizedListener<AsyncListenerHandler>> iterator = marker.getListenerTraversal();
 
                 marker.incrementProcessingDelay();
 
-                // Yes, removing the marker will cause the chain to stop
-                if (list != null) {
-                    Iterator<PrioritizedListener<AsyncListenerHandler>> iterator = list.iterator();
-                    
-                    if (iterator.hasNext()) {
-                        marker.setListenerTraversal(iterator);
-                        iterator.next().getListener().enqueuePacket(packet);
+                if (iterator != null && iterator.hasNext()) {
+                    AsyncListenerHandler handler = marker.getListenerTraversal().next().getListener();
+                    if (!handler.isCancelled()) {
+                        handler.enqueuePacket(packet);
                         continue;
                     }
                 }
+
+                if (iterator == null) {
+                    Collection<PrioritizedListener<AsyncListenerHandler>> list = getListener(packet.getPacketType());
+
+                    // Yes, removing the marker will cause the chain to stop
+                    if (list != null) {
+                        iterator = list.iterator();
+                        
+                        if (iterator.hasNext()) {
+                            marker.setListenerTraversal(iterator);
+                            iterator.next().getListener().enqueuePacket(packet);
+                            continue;
+                        }
+                    }
+                }
 
                 // The packet has no further listeners. Just send it.
                 if (marker.decrementProcessingDelay() == 0) {