(self)
| 12259 | # self.thread_lock.release() |
| 12260 | |
| 12261 | def _queued_thread_event_read(self): |
| 12262 | if self.thread_queue is None: |
| 12263 | return None |
| 12264 | |
| 12265 | try: # see if something has been posted to Queue |
| 12266 | message = self.thread_queue.get_nowait() |
| 12267 | except queue.Empty: # get_nowait() will get exception when Queue is empty |
| 12268 | return None |
| 12269 | |
| 12270 | return message |
| 12271 | |
| 12272 | def _queued_thread_event_available(self): |
| 12273 |
no outgoing calls
no test coverage detected