xiab.py 文件源码

def run_arduino_bridge(self):
        """
        start the bridge
        :return:
        """

        while True:
            if self.last_problem:
                self.report_problem()
            # noinspection PyBroadException
            try:
                z = self.subscriber.recv_multipart(zmq.NOBLOCK)

                self.payload = umsgpack.unpackb(z[1])
                # print("[%s] %s" % (z[0], self.payload))
                command = self.payload['command']
                if command in self.command_dict:
                    self.command_dict[command]()
                else:
                    print("can't execute unknown command'")
                self.board.sleep(.001)
            except zmq.error.Again:
                self.board.sleep(.001)
            # return