issue #20: fix queue.get() parameter list.
This commit is contained in:
parent
19869da087
commit
48bf987570
|
@ -271,7 +271,7 @@ def _queue_interruptible_get(queue, timeout=None, block=True):
|
||||||
msg = None
|
msg = None
|
||||||
while msg is None and (timeout is None or timeout < time.time()):
|
while msg is None and (timeout is None or timeout < time.time()):
|
||||||
try:
|
try:
|
||||||
msg = queue.get(True, 0.5, block=block)
|
msg = queue.get(block, 0.5)
|
||||||
except Queue.Empty:
|
except Queue.Empty:
|
||||||
if block:
|
if block:
|
||||||
break
|
break
|
||||||
|
|
Loading…
Reference in New Issue