Show More
| @@ -47,7 +47,7 b' class BlockingSubSocketChannel(SubSocketChannel):' | |||
|
|
47 | 47 | |
|
|
48 | 48 | def get_msg(self, block=True, timeout=None): |
|
|
49 | 49 | """Get a message if there is one that is ready.""" |
|
|
50 | return self.in_queue.get(block, timeout) | |
|
|
50 | return self._in_queue.get(block, timeout) | |
|
|
51 | 51 | |
|
|
52 | 52 | def get_msgs(self): |
|
|
53 | 53 | """Get all messages that are currently ready.""" |
| @@ -79,7 +79,7 b' class BlockingXReqSocketChannel(XReqSocketChannel):' | |||
|
|
79 | 79 | |
|
|
80 | 80 | def get_msg(self, block=True, timeout=None): |
|
|
81 | 81 | """Get a message if there is one that is ready.""" |
|
|
82 | return self.in_queue.get(block, timeout) | |
|
|
82 | return self._in_queue.get(block, timeout) | |
|
|
83 | 83 | |
|
|
84 | 84 | def get_msgs(self): |
|
|
85 | 85 | """Get all messages that are currently ready.""" |
General Comments 0
You need to be logged in to leave comments.
Login now