mqtt_gobject_bridge.py 文件源码

def _init_socket_handlers(self):
        if self._socket_watch is not None:
            gobject.source_remove(self._socket_watch)
        self._socket_watch = gobject.io_add_watch(self._client.socket().fileno(), gobject.IO_IN,
            self._on_socket_in)
        if self._socket_timer is None:
            self._socket_timer = gobject.timeout_add_seconds(1, exit_on_error, self._on_socket_timer)