(self, wait_for_response=True, thread_id="*")
| 391 | return ret |
| 392 | |
| 393 | def write_continue(self, wait_for_response=True, thread_id="*"): |
| 394 | continue_request = self.write_request(pydevd_schema.ContinueRequest(pydevd_schema.ContinueArguments(threadId=thread_id))) |
| 395 | |
| 396 | if wait_for_response: |
| 397 | if thread_id != "*": |
| 398 | # event, response may be sent in any order |
| 399 | msg1 = self.wait_for_json_message((ContinuedEvent, ContinueResponse)) |
| 400 | msg2 = self.wait_for_json_message((ContinuedEvent, ContinueResponse)) |
| 401 | by_type = self._by_type(msg1, msg2) |
| 402 | continued_ev = by_type[ContinuedEvent] |
| 403 | continue_response = by_type[ContinueResponse] |
| 404 | assert continue_response.request_seq == continue_request.seq |
| 405 | |
| 406 | assert continued_ev.body.allThreadsContinued == False |
| 407 | assert continue_response.body.allThreadsContinued == False |
| 408 | else: |
| 409 | # The continued event is received before the response. |
| 410 | self.wait_for_continued_event(all_threads_continued=True) |
| 411 | continue_response = self.wait_for_response(continue_request) |
| 412 | assert continue_response.body.allThreadsContinued |
| 413 | |
| 414 | def write_pause(self): |
| 415 | pause_request = self.write_request(pydevd_schema.PauseRequest(pydevd_schema.PauseArguments("*"))) |
no test coverage detected