(self)
| 189 | self.close_streams() |
| 190 | |
| 191 | def clear_timeouts(self) -> None: |
| 192 | if self.timeout is not None: |
| 193 | self.io_loop.remove_timeout(self.timeout) |
| 194 | if self.connect_timeout is not None: |
| 195 | self.io_loop.remove_timeout(self.connect_timeout) |
| 196 | |
| 197 | def close_streams(self) -> None: |
| 198 | for stream in self.streams: |
no test coverage detected