har we go
parent
0c4e9fc05f
commit
68b6667c76
|
|
@ -105,11 +105,14 @@ class Reactor(threading.Thread):
|
|||
def run(self):
|
||||
log("Reactor.run: start")
|
||||
while True:
|
||||
got = self.inq.get()
|
||||
if not got:
|
||||
text = self.inq.get()
|
||||
if text is None:
|
||||
break
|
||||
print(got)
|
||||
self.handle(text)
|
||||
log("Reactor.run: stop")
|
||||
|
||||
def handle(self, text):
|
||||
print(text)
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
|
|
|
|||
Loading…
Reference in New Issue