returns internal command queue for a given thread. if new queue is created, notify the RDB about it
(self, thread_id)
| 1592 | self._server_socket = None |
| 1593 | |
| 1594 | def get_internal_queue_and_event(self, thread_id) -> Tuple[_queue.Queue, ThreadingEvent]: |
| 1595 | """returns internal command queue for a given thread. |
| 1596 | if new queue is created, notify the RDB about it""" |
| 1597 | if thread_id.startswith("__frame__"): |
| 1598 | thread_id = thread_id[thread_id.rfind("|") + 1 :] |
| 1599 | return self._cmd_queue[thread_id], self._thread_events[thread_id] |
| 1600 | |
| 1601 | def post_method_as_internal_command(self, thread_id, method, *args, **kwargs): |
| 1602 | if thread_id == "*": |
no outgoing calls
no test coverage detected