o j@s*ddlZd ddZd ddZd ddZdS) NcHtjtj|||dgddiIdH}t|dtr |dS|d)a6 Helper function to read exactly N amount of data from the wire. :param reader: The reader object :type reader: asyncio.StreamReader :param n: The maximum amount of bytes to read. :type n: int :param timeout: Time in seconds to wait for the reader to return data :type timeout: int :return: bytearray timeoutreturn_exceptionsTNr)asynciogatherwait_for readexactly isinstancebytesreadernrtempr/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/asysocks/common/aiowrappers.pyreadexactly_or_excs ( rcr)ak Helper function to read N amount of data from the wire. :param reader: The reader object :type reader: asyncio.StreamReader :param n: The maximum amount of bytes to read. BEWARE: this only sets an upper limit of the data to be read :type n: int :param timeout: Time in seconds to wait for the reader to return data :type timeout: int :return: bytearray rrTNr)rrrreadr r r rrr read_or_exc ( r cr)aj Helper function to read stream until separator is hit. :param reader: The reader object :type reader: asyncio.StreamReader :param n: The maximum amount of bytes to read. BEWARE: this only sets an upper limit of the data to be read :type n: int :param timeout: Time in seconds to wait for the reader to return data :type timeout: int :return: bytearray rrTNr)rrr readuntilr r )r separatorrrrrrreaduntil_or_exc'rr)N)rN)rrrrrrrrs