fix message queue
This commit is contained in:
parent
01c88c7dc8
commit
4a3548f7fd
@ -12,7 +12,4 @@ class MessageHelper:
|
|||||||
self.queue.put(message)
|
self.queue.put(message)
|
||||||
|
|
||||||
def get(self):
|
def get(self):
|
||||||
if not self.queue.empty():
|
return self.queue.get(block=True)
|
||||||
return self.queue.get(block=True)
|
|
||||||
else:
|
|
||||||
return None
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user