async def METHOD_NAME(self, reader: StreamReader):
    len_packed: bytes = await read_data_async(reader, 4)
    payload_len = struct.unpack("!I", len_packed)[0]
    # LOG.debug(f"Got payload len_packed: {len_packed.hex()}, that is: {payload_len}")
    payload = await read_data_async(reader, payload_len)
    data = pickle.loads(payload)
    # LOG.debug(f"Loaded pickable of type: {type(data)}")
    return data