(self)
| 366 | await tasks.sleep(0) |
| 367 | |
| 368 | async def serve_forever(self): |
| 369 | if self._serving_forever_fut is not None: |
| 370 | raise RuntimeError( |
| 371 | f'server {self!r} is already being awaited on serve_forever()') |
| 372 | if self._sockets is None: |
| 373 | raise RuntimeError(f'server {self!r} is closed') |
| 374 | |
| 375 | self._start_serving() |
| 376 | self._serving_forever_fut = self._loop.create_future() |
| 377 | |
| 378 | try: |
| 379 | await self._serving_forever_fut |
| 380 | except exceptions.CancelledError: |
| 381 | try: |
| 382 | self.close() |
| 383 | await self.wait_closed() |
| 384 | finally: |
| 385 | raise |
| 386 | finally: |
| 387 | self._serving_forever_fut = None |
| 388 | |
| 389 | async def wait_closed(self): |
| 390 | """Wait until server is closed and all connections are dropped. |
no test coverage detected