(future, conn)
| 562 | return conn, conn.getpeername() |
| 563 | |
| 564 | async def accept_coro(future, conn): |
| 565 | # Coroutine closing the accept socket if the future is cancelled |
| 566 | try: |
| 567 | await future |
| 568 | except exceptions.CancelledError: |
| 569 | conn.close() |
| 570 | raise |
| 571 | |
| 572 | future = self._register(ov, listener, finish_accept) |
| 573 | coro = accept_coro(future, conn) |