def METHOD_NAME(self, flags=0):
    topic, record = self.subscriber.recv_serialized(
        deserialize=lambda msg: (msg[0].decode(), cloudpickle.loads(msg[1])),
        flags=flags
    )
    return topic, record