viz.py 文件源码

def run(self):
        while not self.stopped():
            ready_event.wait()
            ready_event.clear()
            print('Try to connect...')
            threads.blockingCallFromThread(reactor, partial(reactor.connectTCP, self.ip, self.port, self.factory))
            sleep(2.0)