(self)
| 314 | await self._transport.run() |
| 315 | |
| 316 | def stop_sync(self) -> None: |
| 317 | self._transport.request_stop() |
| 318 | self._dispatcher_fiber.switch() |
| 319 | self._loop.run_until_complete(self._transport.wait_until_stopped()) |
| 320 | self.cleanup() |
| 321 | |
| 322 | async def stop_async(self) -> None: |
| 323 | self._transport.request_stop() |
no test coverage detected