Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
streams.cpython-314.pyc254 linesDownload Raw Back to __pycache__
1+
2��iAo���Rt^RIt^RIt^RIt^RIt^RIt]!]R4'd3]R,
t^RIHt^RIH	t	^RIH4t5^RIHt^R	IHt^R6I
Ht^RIHtRtRR]/R
lltRR]/Rllt]!]R4'dRR]/RlltRR]/Rllt!RR]P,4t!RR]]P,4t!RR4t!RR4tR#)�StreamReader�StreamWriter�StreamReaderProtocolN�AF_UNIX)�7coroutines)�events)�8exceptions)�format_helpers)�	protocols)�logger)�sleep�limitc���a	"�\P!4p\W$R7p\WTR7o	VP!V	3RlW3/VBGRjx�L9wrg\VS	WT4pWX3#L5i)a�A wrapper for create_connection() returning a (reader, writer) pair.10 11The reader returned is a StreamReader instance; the writer is a12StreamWriter instance.13 14The arguments are all the usual arguments to create_connection()15except protocol_factory; most common are positional host and port,16with various optional keyword arguments following.17 18Additional optional keyword arguments are loop (to set the event loop19instance to use) and limit (to set the buffer limit passed to the20StreamReader).21 22(If you want to customize the StreamReader and/or23StreamReaderProtocol classes, just copy the code -- there's24really nothing special here except some convenience.)25�r
�loop�rc�<�S#�N���protocols��Lib\asyncio\streams.py�<lambda>�!open_connection.<locals>.<lambda>1s����N)r�get_running_looprr�create_connectionr)26�host�portr
�kwdsr�reader�	transport�_�writerrs27&&$,     @r�open_connectionr$si����&�"�"�$�D�
��
1�F�#�F�6�H��/�/��$�.�(,�.�.�L�I�
�)�X�v�
<�F��>��.���A	A%�A#�
A%c��aaa"�\P!4oVVV3RlpSP!WQV3/VBGRjx�L28#L5i)aVStart a socket server, call back for each client connected.29 30The first parameter, `client_connected_cb`, takes two parameters:31client_reader, client_writer.  client_reader is a StreamReader32object, while client_writer is a StreamWriter object.  This33parameter can either be a plain callback function or a coroutine;34if it is a coroutine, it will be automatically converted into a35Task.36 37The rest of the arguments are all the usual arguments to38loop.create_server() except protocol_factory; most common are39positional host and port, with various optional keyword arguments40following.  The return value is the same as loop.create_server().41 42Additional optional keyword argument is limit (to set the buffer43limit passed to the StreamReader).44 45The return value is the same as loop.create_server(), i.e. a46Server object which can be used to stop the service.47c�><�\SSR7p\VSSR7pV#�rr�rr�r r�client_connected_cbr
rs  ���r�factory�start_server.<locals>.factoryNs&����E��5��'��0C�-1�3���rN)rr�
create_server)r+rrr
rr,rsf&&d, @r�start_serverr/6s;����,�"�"�$�D���#�#�G�4�@�4�@�@�@�@�s�5A�?�Ac���a"�\P!4p\WR7p\WCR7oVP!V3RlV3/VBGRjx�L48wrV\VSWC4pWG3#L5i)z@Similar to `open_connection` but works with UNIX Domain Sockets.rrc�<�S#rrrs�rr�&open_unix_connection.<locals>.<lambda>bs���HrN)rrrr�create_unix_connectionr)	�pathr
rrr r!r"r#rs	&$,     @r�open_unix_connectionr5Zsi�����&�&�(���E�5��'��:��!�8�8��d�,�&*�,�,��	��i��6�@���~��,�r%c��aaa"�\P!4oVVV3RlpSP!WA3/VBGRjx�L49#L5i)z=Similar to `start_server` but works with UNIX Domain Sockets.c�><�\SSR7p\VSSR7pV#r(r)r*s  ���rr,�"start_unix_server.<locals>.factoryks&���!��D�9�F�+�F�4G�15�7�H��OrN)rr�create_unix_server)r+r4r
rr,rsf&d, @r�start_unix_serverr:fs9�����&�&�(��	��,�,�W�C�d�C�C�C�C�s�4A�>�Ac�La�]tRt^ttoRtR50RltRtRtRtRt	Rt51R	tVtR#)�FlowControlMixinaReusable flow control logic for StreamWriter.drain().52 53This implements the protocol methods pause_writing(),54resume_writing() and connection_lost().  If the subclass overrides55these it must call the super methods.56 57StreamWriter.drain() must wait for _drain_helper() coroutine.58Nc��Vf\P!4VnMWnRVn\P59!4VnRVnR#)NF)r�get_event_loop�_loop�_paused�collections�deque�_drain_waiters�_connection_lost)�selfrs&&r�__init__�FlowControlMixin.__init__~s<���<��.�.�0�D�J��J����)�/�/�1��� %��rc��VP'dQhRVnVPP4'd\P!RV4R#R#)Tz%r pauses writingN)r@r?�	get_debugr�debug�rEs&r�
pause_writing�FlowControlMixin.pause_writing�s?���<�<�<�������:�:���!�!��L�L�,�d�3�"rc�"�VP'gQhRVnVPP4'd\P!RV4VP60F,pVP
4'dKVPR4K.	R#)Fz%r resumes writingN)r@r?rIrrJrC�done�61set_result�rE�waiters& r�resume_writing�FlowControlMixin.resume_writing�sb���|�|�|��|�����:�:���!�!��L�L�-�t�4��)�)�F��;�;�=�=��!�!�$�'�*rc���RVnVP'gR#VPFCpVP4'dKVfVP	R4K2VPV4KE	R#�TN)rDr@rCrOrP�
set_exception�rE�excrRs&& r�connection_lost� FlowControlMixin.connection_lost�sR�� $����|�|�|���)�)�F��;�;�=�=��;��%�%�d�+��(�(��-�*rc��j"�VP'd\R4hVP'gR#VPP	4pVP62P
V4VGRjx�L63VP64PV4R#L! TP65PT4i;i5i)zConnection lostN)rD�ConnectionResetErrorr@r?�
create_futurerC�append�removerQs& r�
_drain_helper�FlowControlMixin._drain_helper�s����� � � �&�'8�9�9��|�|�|�����)�)�+�����"�"�6�*�	/��L�L����&�&�v�.�
�����&�&�v�.�s4�/B3�7B3�*B�/B�0B�4B3�B�B0�0B3c��\hr)�NotImplementedError�rE�streams&&r�_get_close_waiter�"FlowControlMixin._get_close_waiter�s��!�!r)rDrCr?r@r)
�__name__�66__module__�__qualname__�__firstlineno__�__doc__rFrLrSrZrarg�__static_attributes__�__classdictcell__��
__classdict__s@rr<r<ts-�����&�4�(�.�67/�"�"rr<c�~aa�]tRt^�toRtRtR
V3Rllt]R4tRt	Rt68V3RltRtR	t
R69tRtRtVtV;t#)ra)Helper class to adapt between Protocol and StreamReader.70 71(This is a helper class instead of making StreamReader itself a72Protocol subclass, because the StreamReader has other potential73uses, and to prevent the user of the StreamReader to accidentally74call inappropriate methods of the protocol.)75Nc�.<�\SV`VR7Ve.\P!V4VnVP76VnMRVnVeWnRVnRVnRVn	W n77RVnVPP4VnR#)rNF)�superrF�weakref�ref�_stream_reader_wr�_source_traceback�_strong_reader�_reject_connection�_task�78_transport�_client_connected_cb�	_over_sslr?r^�_closed)rE�
stream_readerr+r�	__class__s&&&&�rrF�StreamReaderProtocol.__init__�s����
���d��#��$�%,�[�[��%?�D�"�%2�%D�%D�D�"�%)�D�"��*�#0��"'�����79����$7�!�����z�z�/�/�1��rc�B�VPfR#VP4#r)rwrKs&r�_stream_reader�#StreamReaderProtocol._stream_reader�s ���!�!�)���%�%�'�'rc�Z�VPpWnVPR4RJVnR#)�80sslcontextN)r?r|�get_extra_infor~)rEr!rs&& r�_replace_transport�'StreamReaderProtocol._replace_transport�s'���z�z��#��"�1�1�,�?�t�K��rc�aa�SP'dSRR/pSP'dSPVR&SPPV4SP	4R#SSnSPpVeVPS4SPR4RJSn	SPe�\SSVSP4pSPW44p\P!V4'dCVV3RlpSPPV4SnSPP!V4RSnR#R#)�messagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.�source_tracebackNr�c��<�VP4'dSP4R#VP4pVe4SPP	RRRVRS/4SP4R#R#)Nr�z*Unhandled exception in client_connected_cb�	exceptionr!)�	cancelled�closer�r?�call_exception_handler)�taskrYrEr!s& ��r�callback�6StreamReaderProtocol.connection_made.<locals>.callback�sf����~�~�'�'�!���)���.�.�*�C����81�82�9�9�%�'S�'��'��;��83"���)�
'r)rzrxr?r��abortr|r��
set_transportr�r~r}rr�iscoroutine�create_taskr{�add_done_callbackry)rEr!�contextr r#�resr�sff     r�connection_made�$StreamReaderProtocol.connection_made�s����"�"�"��@��G�84�%�%�%�.2�.D�.D��*�+��J�J�-�-�g�6��O�O���#����$�$����� � ��+�"�1�1�,�?�t�K����$�$�0�!�)�T�6�4�:�:�F�F��+�+�F�;�C��%�%�c�*�*�*�"�Z�Z�3�3�C�8��85��86�87�,�,�X�6�"&�D��)1rc�<�VPpVe'VfVP4MVPV4VPP	4'g<VfVPPR4MVPPV4\SV`V4RVnRVn	RVn88RVnR#r)r��feed_eofrWrrOrPrtrZrw�_stream_writerr{r|)rErYr r�s&& �rrZ�$StreamReaderProtocol.connection_losts�����$�$�����{����!��$�$�S�)��|�|� � �"�"��{����'�'��-����*�*�3�/�
����$�!%���"�����89���rc�L�VPpVeVPV4R#R#r)r��	feed_data)rE�datar s&& r�
data_received�"StreamReaderProtocol.data_receiveds&���$�$�������T�"�rc�n�VPpVeVP4VP'dR#R#)NFT)r�r�r~)rEr s& r�eof_received�!StreamReaderProtocol.eof_receiveds.���$�$�����O�O���>�>�>��rc��VP#r)rres&&rrg�&StreamReaderProtocol._get_close_waiter&s���|�|�rc���VPpVP4'd+VP4'gVP4R#R#R# \dR#i;ir)rrOr�r��AttributeError)rE�closeds& r�__del__�StreamReaderProtocol.__del__)sR��	#��\�\�F��{�{�}�}�V�%5�%5�%7�%7�� � �"�&8�}���	��	�s�A�A�A)90r}rr~rzrxrwr�ryr{r|�NN)rirjrkrlrmrxrF�propertyr�r�r�rZr�r�rgr�rnro�
__classcell__)r�rqs@@rrr�sU�������2�&�(��(�91L�92%'�N�$#�93	��	#�	#rc�a�]tRtRtoRtRtRt]R4tRt	Rt94RtR	tR95t
RtRtRRltRtRR
RR
RR
/Rlt]3RltRtVtR
#)ri5aWraps a Transport.96 97This exposes write(), writelines(), [can_]write_eof(),98get_extra_info() and close().  It adds drain() which returns an99optional Future on which you can wait for flow control.  It also100adds a transport property which references the Transport101directly.102c���WnW nVe\V\4'gQhW0nW@nVP103P
4VnVPPR4R#r)	r|�	_protocol�104isinstancer�_readerr?r^�
_complete_futrP)rEr!rr rs&&&&&rrF�StreamWriter.__init__?sV��#��!���~��F�L�!A�!A�A�A����105�!�Z�Z�5�5�7������%�%�d�+rc���VPPRVP:2.pVPe VP	RVP:24RPRP
V44#)�106transport=zreader=�<{}>� )r�rir|r�r_�format�join�rE�infos& r�__repr__�StreamWriter.__repr__Is[�����'�'�:�d�o�o�5H�)I�J���<�<�#��K�K�'�$�,�,�!1�2�3��}�}�S�X�X�d�^�,�,rc��VP#r�r|rKs&rr!�StreamWriter.transportOs�����rc�<�VPPV4R#r)r|�write�rEr�s&&rr��StreamWriter.writeSs�������d�#rc�<�VPPV4R#r)r|�107writelinesr�s&&rr��StreamWriter.writelinesVs�����"�"�4�(rc�6�VPP4#r)r|�	write_eofrKs&rr��StreamWriter.write_eofYs�����(�(�*�*rc�6�VPP4#r)r|�
can_write_eofrKs&rr��StreamWriter.can_write_eof\s�����,�,�.�.rc�6�VPP4#r)r|r�rKs&rr��StreamWriter.close_s�����$�$�&�&rc�6�VPP4#r)r|�108is_closingrKs&rr��StreamWriter.is_closingbs�����)�)�+�+rc��X"�VPPV4GRjx�L109R#L5ir)r�rgrKs&r�wait_closed�StreamWriter.wait_closedes����n�n�.�.�t�4�4�4�s�*�(�*Nc�8�VPPW4#r)r|r�)rE�name�defaults&&&rr��StreamWriter.get_extra_infohs�����-�-�d�<�<rc��"�VPe!VPP4pVeVhVPP4'd\	^4GRjx�L110VP111P
4GRjx�L112R#L(L5i)zYFlush the write buffer.113 114The intended use is to write115 116  w.write(data)117  await w.drain()118N)r�r�r|r�rr�ra)rErYs& r�drain�StreamWriter.drainksk����<�<�#��,�,�(�(�*�C����	��?�?�%�%�'�'���(�N�N��n�n�*�*�,�,�,�
�,�s*�AB�B�B� !B�B119�B�120B�server_hostname�ssl_handshake_timeout�ssl_shutdown_timeoutc121�� "�VPPRJpVPpVP4GRjx�L122VPP	VP123WaWRVVR7GRjx�L124pWpnVP
V4R#LOL5i)z3Upgrade an existing stream-based connection to TLS.N)�server_sider�r�r�)r�r}r�r?�	start_tlsr|r�)rEr�r�r�r�r�r�
new_transports&&$$$   rr��StreamWriter.start_tls�s����125�n�n�9�9��E���>�>���j�j�l���"�j�j�2�2��O�O�X�#�"7�!5�	3�7�7�
�126(���#�#�M�2�	�7�s!�8B�B127�1B�,B�-B�Bc��VPP4'ggVPP4'dVP!R\1284R#VP
4VP!RV:2\1294R#R#)zloop is closedz	unclosed N)r|r�r?�	is_closed�warn�ResourceWarningr�)rE�warningss&&rr��StreamWriter.__del__�sZ�����)�)�+�+��z�z�#�#�%�%��
�
�.��@��130�131���
�
�	�$��2�O�D�,r)r�r?r�r�r|r)rirjrkrlrmrFr�r�r!r�r�r�r�r�r�r�r�r�r�r�r�rnrorps@rrr5s������,�-�����$�)�+�/�'�,�5�=�-�23�(,�3�.2�3�.2�3�  (�E�Erc�a�]tRtRtoRt]R3RltRtRtRt	Rt132RtR	tR133t
RtRtR
tRtRRltRRltRtRtRtRtVtR#)ri�Nc��V^8:d\R4hWnVf\P!4VnMW n\4VnRVnRVnRVn	RVn134RVnVPP4'd2\P!\P !^44VnR#R#)�zLimit cannot be <= 0NF)�135ValueError�_limitrr>r?�	bytearray�_buffer�_eof�_waiter�136_exceptionr|r@rIr	�
extract_stack�sys�	_getframerx)rEr
rs&&&rrF�StreamReader.__init__�s����A�:��3�4�4����<��.�.�0�D�J��J� �{�����	��������������:�:���!�!�%3�%A�%A��
�
�a� �&"�D�"�"rc���R.pVP'd(VP\VP4R24VP'dVPR4VP\1378wdVPRVP24VP'd VPRVP:24VP'd VPRVP:24VP'd VPRVP:24VP'dVPR4RPR	PV44#)138rz bytes�eofzlimit=zwaiter=z139exception=r��pausedr�r�)r�r_�lenr�r��_DEFAULT_LIMITr�r�r|r@r�r�r�s& rr��StreamReader.__repr__�s�������<�<�<��K�K�3�t�|�|�,�-�V�4�5��9�9�9��K�K����;�;�.�(��K�K�&����
�.�/��<�<�<��K�K�'�$�,�,�!1�2�3��?�?�?��K�K�*�T�_�_�$7�8�9��?�?�?��K�K�*�T�_�_�$7�8�9��<�<�<��K�K��!��}�}�S�X�X�d�^�,�,rc��VP#r)r�rKs&rr��StreamReader.exception�s�����rc��WnVPpVe3RVnVP4'gVPV4R#R#R#r)r�r�r�rWrXs&& rrW�StreamReader.set_exception�sD�����������D�L��#�#�%�%��$�$�S�)�&�rc��VPpVe3RVnVP4'gVPR4R#R#R#)z1Wakeup read*() functions waiting for data or EOF.N)r�r�rPrQs& r�_wakeup_waiter�StreamReader._wakeup_waiter�s?���������D�L��#�#�%�%��!�!�$�'�&�rc�<�VPeQR4hWnR#)NzTransport already setr�)rEr!s&&rr��StreamReader.set_transport�s�����&�?�(?�?�&�#�rc��VP'dJ\VP4VP8:d$RVnVPP4R#R#R#)FN)r@rr�r�r|�resume_readingrKs&r�_maybe_resume_transport�$StreamReader._maybe_resume_transport�s=���<�<�<�C����-����<� �D�L��O�O�*�*�,�=�<rc�4�RVnVP4R#rV)r�rrKs&rr��StreamReader.feed_eof�s����	����rc�L�VP;'dVP'*#)z=Return True if the buffer is empty and 'feed_eof' was called.)r�r�rKs&r�at_eof�StreamReader.at_eof�s���y�y�-�-����-�-rc��VP'dQR4hV'gR#VPPV4VP4VPefVP140'gR\
VP4^VP,8�d%VPP4RVnR#R#R#R# \dRTnR#i;i)zfeed_data after feed_eofNT)141r�r��extendrr|r@rr��
pause_readingrdr�s&&rr��StreamReader.feed_data�s����9�9�9�8�8�8�}��������D�!������O�O�'��L�L�L��D�L�L�!�A����O�3�
$����-�-�/� $���4�!�
(��142'�
'�#'���	
'�s�C�C�Cc��p"�VPe\VR24hVP'dQR4hVP'd"RVnVPP4VPP4VnVPGRjx�L143RVnR#L
 RTni;i5i)z`Wait until feed_data() or feed_eof() is called.144 145If stream was paused, automatically resume it.146NzF() called while another coroutine is already waiting for incoming dataz_wait_for_data after EOFF)r��RuntimeErrorr�r@r|rr?r^)rE�	func_names&&r�_wait_for_data�StreamReader._wait_for_datas�����<�<�#���+�4�5�6�
6��9�9�9�8�8�8�}��<�<�<� �D�L��O�O�*�*�,��z�z�/�/�1���	 ��,�,����D�L�
���D�L�s;�.B6�B6�147AB6�B*�B(�B*�	B6�(B*�*	B3�3B6c��"�Rp\V4pVPV4GRjx�L148pV#L \PdpTPuRp?#Rp?i\P149d�pTPPYP4'd"TPRTPT,1MTPP4TP4\TP^,4hRp?ii;i5i)a�Read chunk of data from the stream until newline (b'150') is found.151 152        On success, return chunk that ends with newline. If only partial153        line can be read due to EOF, return incomplete line without154        terminating newline. When EOF was reached while no bytes read, empty155        bytes object is returned.156 157        If limit is reached, ValueError will be raised. In that case, if158        newline was found, complete line including newline will be removed159        from internal buffer. Else, internal buffer will be cleared. Limit is160        compared against part of the line without newline.161 162        If stream was paused, this function will automatically resume it if163        needed.164        �165N)
r�	readuntilr�IncompleteReadError�partial�LimitOverrunErrorr��166startswith�consumed�clearrr��args)rE�sep�seplen�line�es&    r�readline�StreamReader.readlines���� ���S���167	(�����,�,�D���-���-�-�	��9�9����+�+�	(��|�|�&�&�s�J�J�7�7��L�L�!5�!�*�*�v�"5�!5�6����"�"�$��(�(�*��Q�V�V�A�Y�'�'��
	(�sP�D�.�,�.�D�.�D�A�D�D�D�+D�,BC>�>D�Dc��N"�\V\4'd\V\R7pMV.pV'g\	R4h\V^,4p\VR,4pV^8Xd\	R4hVP168e
VP169h^p\VP4pWT,170V8�d�RpRpVFIpVPPW�4p	V	R8wgK'V	\V4,p171Ve	W�8gKET172pT	pKK	VeM�\^V^,V,1734pW@P8�d\P!RV4hVP'dG\VP4pVPP4\P!VR4hVP!R4GRjx�L174EK0W`P8�d\P!RV4hVPRVpVPRV1VP#4\V4#Lg5i)	a�Read data from the stream until ``separator`` is found.175 176On success, the data and separator will be removed from the177internal buffer (consumed). Returned data will include the178separator at the end.179 180Configured stream limit is used to check result. Limit sets the181maximal length of data that can be returned, not counting the182separator.183 184If an EOF occurs and the complete separator is still not found,185an IncompleteReadError exception will be raised, and the internal186buffer will be reset.  The IncompleteReadError.partial attribute187may contain the separator partially.188 189If the data cannot be read because of over limit, a190LimitOverrunError exception  will be raised, and the data191will be left in the internal buffer, so it can be read again.192 193The ``separator`` may also be a tuple of separators. In this194case the return value will be the shortest possible that has any195separator as the suffix. For the purposes of LimitOverrunError,196the shortest possible separator is considered to be the one that197matched.198)�keyz-Separator should contain at least one elementz,Separator should be at least one-byte stringNz2Separator is not found, and chunk exceed the limitr$z2Separator is found, but chunk is longer than limit�����)r��tuple�sortedrr�r�r��find�maxr�rr'r��bytesr*r%r r)rE�	separator�199min_seplen�200max_seplen�offset�buflen�match_start�	match_endr,�isep�end�chunks&&          rr$�StreamReader.readuntil>s����4�i��'�'��y�c�2�I�"��I���L�M�M���1��&�201���2��'�202���?��K�L�L��?�?�&��/�/�!�*�������&�F���*�,�"�� �	�$�C��<�<�,�,�S�9�D��r�z�#�S��X�o��$�,���(+�I�*.�K�%��(���Q���203�Z� 7�8���K�K�'�$�6�6�L�� � ��y�y�y��d�l�l�+�����"�"�$� �4�4�U�D�A�A��%�%�k�2�2�2����$��.�.�D�k�S�
S����Z�i�(���L�L��)��$��$�$�&��U�|��
3�s,�3H%�B(H%�#H%�AH%�!AH%�;H#�<A(H%c��204"�VPe
VPhV^8XdR#V^8dT.pVPVP4GRjx�L205pV'gMVPV4K@RP	V4#VP206'g,VP'gVPR4GRjx�L207\\VP2084RV4pVP209RV1VP4V#L�LH5i)a]Read up to `n` bytes from the stream.210 211If `n` is not provided or set to -1,212read until EOF, then return all read bytes.213If EOF was received and the internal buffer is empty,214return an empty bytes object.215 216If `n` is 0, return an empty bytes object immediately.217 218If `n` is positive, return at most `n` available bytes219as soon as at least 1 byte is available in the internal buffer.220If EOF is received before any byte is read, return an empty221bytes object.222 223Returned value is not limited with limit, configured at stream224creation.225 226If stream was paused, this function will automatically resume it if227needed.228Nr�read)r�rFr�r_r�r�r�r r9�229memoryviewr)rE�n�blocks�blockr�s&&   rrF�StreamReader.read�s����,�?�?�&��/�/�!���6���q�5�230�F��"�i�i����4�4�����
�
�e�$��8�8�F�#�#��|�|�|�D�I�I�I��%�%�f�-�-�-��Z����-�b�q�1�2���L�L��!����$�$�&���5�
.�s7�AD�C?�D�6D�D�$D�8D�9AD�Dc��"�V^8d\R4hVPe
VPhV^8XdR#\VP4V8dsVP'dF\VP4pVPP
4\P!W!4hVPR4GRjx�L231K�\VP4V8Xd1\VP4pVPP
4M0\\VP4RV4pVPRV1VP4V#L�5i)a�Read exactly `n` bytes.232 233Raise an IncompleteReadError if EOF is reached before `n` bytes can be234read. The IncompleteReadError.partial attribute of the exception will235contain the partial read bytes.236 237if n is zero, return empty bytes object.238 239Returned value is not limited with limit, configured at stream240creation.241 242If stream was paused, this function will automatically resume it if243needed.244z*readexactly size can not be less than zeroNr�readexactly)r�r�rr�r�r9r*rr%r rGr)rErH�245incompleter�s&&  rrM�StreamReader.readexactly�s���
�q�5��I�J�J��?�?�&��/�/�!���6���$�,�,��!�#��y�y�y�"�4�<�<�0�246����"�"�$� �4�4�Z�C�C��%�%�m�4�4�4��t�|�|���!�����&�D��L�L��� ���D�L�L�1�"�1�5�6�D����R�a�R� ��$�$�&���
5�s�A!E�$AE�=E�>BEc��V#rrrKs&r�	__aiter__�StreamReader.__aiter__s���rc��\"�VP4GRjx�L247pVR8Xd\hV#L5i)Nr)r0�StopAsyncIteration)rE�vals& r�	__anext__�StreamReader.__anext__s*����M�M�O�#���#�:�$�$��248�$�s�,�*�,)	r�r�r�r�r?r@rxr|r�)r#)r4)rirjrkrlrxrrFr�r�rWrr�rr�rr�r r0r$rFrMrQrVrnrorps@rrr�sn������+�$�"�,-�$�*�(�$�-�249�.�$�, �8�>p�d1�f'�R��r)rrrr$r/)r5r:ir�r)�__all__rA�socketr�r�ru�hasattr�rrrr	r250�logr�tasksrrr$r/r5r:�Protocolr<rrrrrr�<module>r_s���'���
�251���252�6�9����<�<�G����������� .��8A�+�A�B�6�9���253�)7�254�D�&4�D�="�y�)�)�="�@~#�+�Y�-?�-?�~#�BeE�eE�Nw�wr
codekingpro/portable-devtools · Team Ai