Show More
@@ -35,6 +35,10 b' class BlockingChannelMixin(object):' | |||
|
35 | 35 | |
|
36 | 36 | def get_msg(self, block=True, timeout=None): |
|
37 | 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 | 42 | return self._in_queue.get(block, timeout) |
|
39 | 43 | |
|
40 | 44 | def get_msgs(self): |
General Comments 0
You need to be logged in to leave comments.
Login now