Function deserialize

tests/test_pgext.py:487–503

(data)

def deserialize(data):
    buf = memoryview(data)

    while buf:
        msg_type = bytes(buf[:1])
        msg_size = struct.unpack("!I", buf[1:5])[0]
        payload = buf[5 : msg_size + 1]
        cls = messages_by_type.get(msg_type)
        if cls is None:
            if DEBUG:
                print(PID, "<  ", "skipping:", bytes(buf[: msg_size + 1]))
        else:
            rv = cls.deserialize(payload)
            if DEBUG:
                print(PID, "<  ", rv)
            yield rv
        buf = buf[msg_size + 1:]


class PgProtocol(asyncio.Protocol):