Function _poll_cancellation

pymongo/network_layer.py:242–247

(conn: AsyncConnection)

async def _poll_cancellation(conn: AsyncConnection) -> None:
    while True:
        if conn.cancel_context.cancelled:
            return

        await asyncio.sleep(_POLL_TIMEOUT)


async def async_receive_data_socket(