(self, idle_window: float = 0.2)
| 161 | self._drain_pending_output() |
| 162 | |
| 163 | def _drain_pending_output(self, idle_window: float = 0.2) -> None: |
| 164 | if self.session is None: |
| 165 | return |
| 166 | |
| 167 | deadline = time.time() + idle_window |
| 168 | while time.time() < deadline: |
| 169 | if self.session.recv_ready(): |
| 170 | self.session.recv(4096) |
| 171 | deadline = time.time() + idle_window |
| 172 | else: |
| 173 | time.sleep(0.05) |
| 174 | |
| 175 | def _normalize_command(self, command: str) -> str: |
| 176 | command = command.strip() |
no outgoing calls
no test coverage detected