Waits for the message loop to terminate, and for all enqueued Response message handlers to finish executing.
(self)
| 1156 | self._parser_thread.start() |
| 1157 | |
| 1158 | def wait(self): |
| 1159 | """Waits for the message loop to terminate, and for all enqueued Response |
| 1160 | message handlers to finish executing. |
| 1161 | """ |
| 1162 | parser_thread = self._parser_thread |
| 1163 | try: |
| 1164 | if parser_thread is not None: |
| 1165 | parser_thread.join() |
| 1166 | except AssertionError: |
| 1167 | log.debug("Handled error joining parser thread.") |
| 1168 | try: |
| 1169 | handler_thread = self._handler_thread |
| 1170 | if handler_thread is not None: |
| 1171 | handler_thread.join() |
| 1172 | except AssertionError: |
| 1173 | log.debug("Handled error joining handler thread.") |
| 1174 | |
| 1175 | # Order of keys for _prettify() - follows the order of properties in |
| 1176 | # https://microsoft.github.io/debug-adapter-protocol/specification |