Method run

src/plugins/map/examples/test_map.py:114–129

(self)

        threading.Thread.__init__(self)

    def run(self):
        print("Starting ")
        i = 0
        while True:
            msg = vpe_api_read()
            if msg:
                # print msg
                id = unpack(">H", msg[0:2])
                size = unpack(">H", msg[2:4])
                print(f"Received {id} of size {size}")
                i += 1
                # del msg
                continue

            # time.sleep(0.001)
        return


# Create RX thread