Function stream

src/util/Msgpack.py:20–38

(data, writer)

def stream(data, writer):
    packer = msgpack.Packer(use_bin_type=True)
    writer(packer.pack_map_header(len(data)))
    for key, val in data.items():
        writer(packer.pack(key))
        if isinstance(val, io.IOBase):  # File obj
            max_size = os.fstat(val.fileno()).st_size - val.tell()
            size = min(max_size, val.read_bytes)
            bytes_left = size
            writer(msgpackHeader(size))
            buff = 1024 * 64
            while 1:
                writer(val.read(min(bytes_left, buff)))
                bytes_left = bytes_left - buff
                if bytes_left <= 0:
                    break
        else:  # Simple
            writer(packer.pack(val))
    return size


class FilePart(object):