sourada-e5

class ObjectStreamReader(object):
    def __init__(self, s):
        self.stream = s
        self.stream.read(2 + 2)
        self.cur_block_remaining = self.get_block_length()

    def get_block_length(self):
        type = ord(self.stream.read(1)[0])
        if type == 0x7a:
            return struct.unpack('>i', self.stream.read(4))[0]