Class Frame

src/main/java/org/jetlang/web/WebSocketReader.java:125–187

    }

    private class Frame implements NioReader.State {

        private ContentType t;
        private boolean fin;
        private boolean isFragment;

        private NioReader.State init(ContentType t, boolean fin, boolean isFragment) {
            if (t != null && !fin && !t.canBeFragmented) {
                return closeOnError(t + " cannot be fragmented.");
            }
            this.t = t;
            this.fin = fin;
            this.isFragment = isFragment;
            return this;
        }

        @Override
        public NioReader.State processBytes(ByteBuffer bb) {
            byte b = bb.get();
            final int size = (byte) (0x7F & b);
            final boolean frameMasked = (b & 0x80) != 0;
            if (size >= 0 && size <= 125) {
                return bodyReadinit(size, t, fin, isFragment, frameMasked);
            }
            if (t != null && !t.canBeFragmented) {
                return closeOnError(t + " Max Size of 125.");
            }
            if (size == 126) {
                return new NioReader.State() {
                    @Override
                    public int minRequiredBytes() {
                        return 2;
                    }

                    @Override
                    public NioReader.State processBytes(ByteBuffer bb) {
                        int size = ((bb.get() & 0xFF) << 8) + (bb.get() & 0xFF);
                        return bodyReadinit(size, t, fin, isFragment, frameMasked);
                    }
                };
            }
            if (size == 127) {
                return new NioReader.State() {
                    @Override
                    public int minRequiredBytes() {
                        return 8;
                    }

                    @Override
                    public NioReader.State processBytes(ByteBuffer bb) {
                        return bodyReadinit((int) bb.getLong(), t, fin, isFragment, frameMasked);
                    }
                };
            }
            handler.onError(connection, state, "Unsupported size: " + size);
            return createClose();
        }