def single_pull(self, ip_text_input, port_text_input):
"""Trigger the reactor to pull from the specified client."""
ip = ip_text_input.value
port = int(port_text_input.value)
factory = PullClientFactory(self, doc, ready_event)
threads.blockingCallFromThread(reactor, partial(reactor.connectTCP, ip, port, factory))
评论列表
文章目录