KCP kcp = new KCP(10) {
    @Override
    protected void output(byte[] bytes, int size) {
        IoBuffer buff = IoBuffer.allocate(size);
        buff.put(bytes, 0, size);
        buff.rewind();
        session.write(buff);
    }
};