| 154 | """reader thread reads and dispatches commands in an infinite loop""" |
| 155 | |
| 156 | def __init__(self, sock, py_db, PyDevJsonCommandProcessor, process_net_command, terminate_on_socket_close=True): |
| 157 | assert sock is not None |
| 158 | PyDBDaemonThread.__init__(self, py_db) |
| 159 | self.__terminate_on_socket_close = terminate_on_socket_close |
| 160 | |
| 161 | self.sock = sock |
| 162 | self._buffer = b"" |
| 163 | self.name = "pydevd.Reader" |
| 164 | self.process_net_command = process_net_command |
| 165 | self.process_net_command_json = PyDevJsonCommandProcessor(self._from_json).process_net_command_json |
| 166 | |
| 167 | def _from_json(self, json_msg, update_ids_from_dap=False): |
| 168 | return pydevd_base_schema.from_json(json_msg, update_ids_from_dap, on_dict_loaded=self._on_dict_loaded) |