Show More
@@ -35,6 +35,10 b' class BlockingChannelMixin(object):' | |||||
35 |
|
35 | |||
36 | def get_msg(self, block=True, timeout=None): |
|
36 | def get_msg(self, block=True, timeout=None): | |
37 | """ Gets a message if there is one that is ready. """ |
|
37 | """ Gets a message if there is one that is ready. """ | |
|
38 | if timeout is None: | |||
|
39 | # Queue.get(timeout=None) has stupid uninteruptible | |||
|
40 | # behavior, so wait for a week instead | |||
|
41 | timeout = 604800 | |||
38 | return self._in_queue.get(block, timeout) |
|
42 | return self._in_queue.get(block, timeout) | |
39 |
|
43 | |||
40 | def get_msgs(self): |
|
44 | def get_msgs(self): |
General Comments 0
You need to be logged in to leave comments.
Login now