PacketDecoder fixed. #200

10 years ago · e84b7bfa81
1 changed files with 2 additions and 1 deletions
--- a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
+++ b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
@ -113,8 +113,9 @@ public class PacketDecoder {
                    return false;
                }
            }
+            return true;
        }
-        return true;
+        return false;
    }

    public Packet decodePackets(ByteBuf buffer, ClientHead client) throws IOException {