(self)
| 320 | self.cleanup() |
| 321 | |
| 322 | async def stop_async(self) -> None: |
| 323 | self._transport.request_stop() |
| 324 | await self._transport.wait_until_stopped() |
| 325 | self.cleanup() |
| 326 | |
| 327 | def cleanup(self, cause: str = None) -> None: |
| 328 | self._closed_error = TargetClosedError(cause) if cause else TargetClosedError() |
no test coverage detected