Function wait_closed

asyncpg/compat.py:45–53

(stream: asyncio.StreamWriter)

async def wait_closed(stream: asyncio.StreamWriter) -> None:
    # Not all asyncio versions have StreamWriter.wait_closed().
    if hasattr(stream, 'wait_closed'):
        try:
            await stream.wait_closed()
        except ConnectionResetError:
            # On Windows wait_closed() sometimes propagates
            # ConnectionResetError which is totally unnecessary.
            pass


if sys.version_info < (3, 12):