hyperionplatform.py 文件源码

def init_connection(self):
        logger.debug('Initializing connection')
        if self._pconfig['verbose']:
            websocket.enableTrace(True)
        self.socket = websocket.WebSocketApp(self.service,
                on_message=self.on_socket_message,
                on_close=self.on_socket_close,
                on_error=self.on_socket_error)
        self.socket_thread = threading.Thread(target=self.socket.run_forever)
        self.socket_thread.daemon = True
        self.socket_thread.start()