Multiple attachment handling for polling transport. #178

11 years ago · 46adf26ba0
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
+++ b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
@ -182,7 +182,9 @@ public class PacketDecoder {
            frame.readByte();
            int headEndIndex = frame.bytesBefore((byte)-1);
            int len = (int) readLong(frame, headEndIndex);
-            frame.readShort();
+            ByteBuf oldFrame = frame;
+            frame = frame.slice(oldFrame.readerIndex() + 1, len);
+            oldFrame.readerIndex(oldFrame.readerIndex() + 1 + len);
        }

        if (frame.getByte(0) == 'b' && frame.getByte(1) == '4') {