Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
web_response.cpython-313.pyc167 linesDownload Raw Back to __pycache__
1�

2��jv����SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK	J3r4 SSKJr SSK
Jr SSKJrJrJrJrJrJrJrJr SSKJrJr SSKJrJr SS	KJr SS5K J!r! SSK"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r, SSKJ-r-J.r.J/r/ SS
KJ0r0 SSK1J2r2J3r3 \Vs0sHoRhURj_M snr6Sr7Sr8\(aSSK9J:r: \\;\4r<O\R<R(r<"SS\Rz5r>\>Vs0sHoRhU_M snr?"SS\<\&5r@"SS\@5rA\*4SSSSSS\R�S.S\S\\;S\\CS\DS\\;S \\3S!\;S"\2S#\A4S$jjjrEgs snfs snf)%�N)�Executor)�6HTTPStatus)�SimpleCookie)�
TYPE_CHECKING�Any�Dict�Iterator�MutableMapping�Optional�Union�cast)�CIMultiDict�istr�)�hdrs�payload)�AbstractStreamWriter)�ZLibCompressor)7�ETAG_ANY�QUOTED_ETAG_RE�ETag�HeadersMixin�must_be_empty_body�parse_http_date�rfc822_formatted_time�sentinel�should_remove_content_length�validate_etag_value)�SERVER_SOFTWARE�
HttpVersion10�
HttpVersion11)�Payload)�JSONEncoder�LooseHeadersi)�
ContentCoding�StreamResponse�Response�
json_response)�BaseRequestc� �\rSrSrSrSrSrSrg)r%�;�deflate�gzip�identity�N)�__name__�8__module__�__qualname__�__firstlineno__r,r-r.�__static_attributes__r/��ZD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/web_response.pyr%r%;s��9�G��D��Hr5r%c��^�\rSrSr%\S\\\4\S'Sr	Sr10Sr\\
\S'Sr\
\S'Sr\
\S'Sr\\\S	'Sr\\\S11'Sr\S\S'Sr\\\S
'Sr\
\S'Sr\\
\S'SrSr\\\S'SrSSSSS.S\S\\S\\S\\\SS412Sjjr \!S\
4Sj5r"\!SaSj5r#\!S\4Sj5r$\!S\
4Sj5r%\!S\
4Sj5r&\!S\4Sj5r'SbS\S\\SS4S jjr(S\S\\SS4S!jr)\!S\\
4S"j5r*ScS#jr+\!S\4S$j5r,\!S\4S%j5r-SbS&\\SS4S'jjr.SdS(\\\
\4S)\\SS4S*jjr/\!SeS+j5r0\!S\4S,j5r1SSSS-SSSSSS..	S/\S0\S1\\S2\\S3\\\\4S4\S5\\
S6\\
S7\\S8\\S9\\
SS4S:jjr2SS-SSSS;.S/\S2\\S4\S5\\
S6\\
S8\\SS4S<jjr3\!S\\4U4S=jj5r4\4RjS0\\SS4S>j5r4\!S\4U4S?jj5r6\6RjS0\SS4S@j5r6\!S\\4U4SAjj5r7\7RjS0\\SS4SBj5r7\!S\\8Rp4SCj5r9\9RjS0\\\\:\8Rp\4SS4SDj5r9\!S\\;4SEj5r<\<RjS0\\\;\4SS4SFj5r<\=R|4SG\?SS4SHjjr@SI\SS4SJjrASfSLjrBSKSS\\4SMjrCSKSS\4SNjrDScSOjrEScSPjrFSQ\\\\G4SS4SRjrHScSSjrISgSQ\SS4STjjrJS\4SUjrKSV\S\L4SWjrMSV\S0\LSS4SXjrNSV\SS4SYjrOS\4SZjrPS\Q\4S[jrRS\4S\jrSS]\TS\
4S^jrUS\
4S_jrVS`rWU=rX$)hr&�LN�_bodyT�_keep_aliveF�_chunked�_compression�_compression_strategy�_compression_forcer)�_req�_payload_writer�	_eof_sent�_must_be_empty_bodyr�_cookies��)�status�reason�headers�
_real_headersrErFrGrH�returnc��0UlUbX@lO#Ub[U5UlO[5UlURX5 g)aInitialize a new stream response object.13 14_real_headers is an internal parameter used to pass a pre-populated15headers object. It is used by the `Response` class to avoid copying16the headers when creating a new response object. It is not intended17to be used by external code.18N)�_state�_headersr�_set_status)�selfrErFrGrHs     r6�__init__�StreamResponse.__init__^s?��')����$�)�M�
�
 �.9�'�.B�D�M�'�M�D�M�����(r5c�D�UR=(d URSL$�N)rAr@�rNs r6�prepared�StreamResponse.preparedxs���~�~�A��!5�!5�T�!A�Ar5c�R�UR(aURR$grR)r?�taskrSs r6rW�StreamResponse.task|s���9�9��9�9�>�>�!�r5c��UR$rR)�_statusrSs r6rE�StreamResponse.status�����|�|�r5c��UR$rR)r;rSs r6�chunked�StreamResponse.chunked�����}�}�r5c��UR$rR)r<rSs r6�compression�StreamResponse.compression����� � � r5c��UR$rR)�_reasonrSs r6rF�StreamResponse.reason�r\r5c�V�UR(aS5eURX5 g)NzGCannot change the response status code after the headers have been sent)rTrM�rNrErFs   r6�19set_status�StreamResponse.set_status�s+���
�
�	U�T�	U������(r5c��[U5UlUc![RURS5nOSU;dSU;a[	S5eX lg)N��
�20zReason cannot contain \r or \n)�intrZ�REASON_PHRASES�get�21ValueErrorrfris   r6rM�StreamResponse._set_status�sF���6�{����>�#�'�'����b�9�F�
�V�^�t�v�~��?�@�@��r5c��UR$rR�r:rSs r6�22keep_alive�StreamResponse.keep_alive�s�����r5c��SUlg)NFrvrSs r6�force_close�StreamResponse.force_close�s23�� ��r5c��UR$rR)�_body_lengthrSs r6�body_length�StreamResponse.body_length�rdr5c��[R"S[5 UR(deURR$)Nzoutput_length is deprecated)�warnings�warn�DeprecationWarningr@�buffer_sizerSs r6�
output_length�StreamResponse.output_length�s3���
�
�3�5G�H��#�#�#�#��#�#�/�/�/r5�24chunk_sizec��[RUR;a[S5eUb[R25"S[5 SUlg)z,Enables automatic chunked transfer encoding.z>You can't enable chunked encoding when a content length is setNzChunk size is deprecated #1615T)r�CONTENT_LENGTHrL�RuntimeErrorr�r�r�r;)rNr�s  r6�enable_chunked_encoding�&StreamResponse.enable_chunked_encoding�sC�����$�-�-�/��P��
��!��M�M�:�<N�O���
r5�force�strategyc��[U[5(aCU(a[RO[Rn[26R"S[5 OUb[U[5(dS5eSUlXl	X l27g)z&Enables response compression encoding.z+Using boolean for force is deprecated #3318Nz1force should one of None, bool or ContentEncodingT)�28isinstance�boolr%r,r.r�r�r�r<r>r=)rNr�r�s   r6�enable_compression�!StreamResponse.enable_compression�s|���e�T�"�"�-2�M�)�)�
�8N�8N�E��M�M�=�?Q�
��
���}���
C�B�
C��!���"'��%-�"r5c��UR$rR)rLrSs r6rG�StreamResponse.headers�r`r5c�R�URc[5UlUR$rR)rCrrSs r6�cookies�StreamResponse.cookies�s���=�=� �(�N�D�M��}�}�r5�/)	�expires�domain�max_age�path�secure�httponly�version�samesite�partitioned�name�valuer�r�r�r�r�r�r�r�r�c	�J�URc[5UlX RU'URUnUbX<S'OURS5S:XaUS	UbXLS'Ub[U5US'O	SU;aUS	XlS'UbX|S'UbX�S'U	bX�S	'U29bX�S30'UbX�S'gg)z�Set or update response cookie.31 32Sets new cookie or updates existent with new value.33Also updates only those params which are not None.34Nr��Thu, 01 Jan 1970 00:00:00 GMTr�zmax-ager�r�r�r�r�r�)rCrrr�str)
rNr�r�r�r�r�r�r�r�r�r�r��cs
             r6�35set_cookie�StreamResponse.set_cookie�s���(�=�=� �(�N�D�M�#�
�
�d���M�M�$�����"�i�L�
�U�U�9�
�!@�
@��)���� �h�K����w�<�A�i�L�
�!�^��)���&�	��� �h�K���$�j�M���"�i�L���$�j�M��"�*�m��#r5)r�r�r�r�r�c��URbURRUS5 URUSSSUUUUUS9	 g)z2Delete cookie.36 37Creates new empty expired cookie.38Nrmrr�)r�r�r�r�r�r�r�)rC�popr�)rNr�r�r�r�r�r�s       r6�39del_cookie�StreamResponse.del_cookiesN���=�=�$��M�M���d�D�)�������3������	�40	41r5c�>�[TU]$rR)�super�content_length�rN�	__class__s �r6r��StreamResponse.content_length1s����w�%�%r5c���UbN[U5nUR(a[S5e[U5UR[42R'gURR[43RS5 g)Nz<You can't set content length when chunked encoding is enable)rpr;r�r�rLrr�r��rNr�s  r6r�r�6s\������J�E��}�}�"�R���25�U��D�M�M�$�-�-�.��M�M���d�1�1�4�8r5c�>�[TU]$rR)r��content_typer�s �r6r��StreamResponse.content_typeBs����w�#�#r5c�\�UR [U5UlUR5 grR)r�r��
_content_type�_generate_content_type_headerr�s  r6r�r�Gs#����� ��Z����*�*�,r5c�>�[TU]$rR)r��charsetr�s �r6r��StreamResponse.charsetMs����w��r5c��URnUS:Xa[S5eURceUcURRSS5 O&[	U5R5URS'UR
5 g)N�application/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstr�)r�r��
_content_dictr�r��lowerr�)rNr��ctypes   r6r�r�Rs����!�!���.�.��?��
��!�!�-�-�-��=����"�"�9�d�3�,/��J�,<�,<�,>�D���y�)��*�*�,r5c�f�[URR[R55$)zeThe value of Last-Modified HTTP header, or None.44 45This header is represented as a `datetime` object.46)rrLrrr�
LAST_MODIFIEDrSs r6�
last_modified�StreamResponse.last_modifiedas$���t�}�}�0�0��1C�1C�D�E�Er5c��Uc+URR[RS5 g[	U[47[45(a[[R"S[R"[R"U555UR[R'g[	U[R5(aA[R"SUR55UR[R'g[	U[5(aXR[R'gS[U5R 3n[#U5e)Nz%a, %d %b %Y %H:%M:%S GMTz$Unsupported type for last_modified: )rLr�rr�r�rp�float�time�strftime�gmtime�math�ceil�datetime�utctimetupler��typer0�	TypeError)rNr��msgs   r6r�r�is����=��M�M���d�0�0�$�7�
���U�|�
,�
,�04�
�
�+�T�[�[����5�9I�-J�1�D�M�M�$�,�,�-���x�0�0�
1�
1�04�
�
�+�U�-?�-?�-A�1�D�M�M�$�,�,�-���s�
#�
#�05�M�M�$�,�,�-�8��e��9M�9M�8N�O�C��C�.� r5c��URR[R5nU(dgU[:Xa
[[S9$[R"U5nU(dgURSS5up4[[U5US9$)N)r�r�)�is_weakr�)48rLrrr�ETAGrrr�	fullmatch�groupr�)rN�quoted_value�matchr�r�s     r6�etag�StreamResponse.etag}sr���}�}�(�(����3����
�X�
%��h�'�'��(�(��6�������Q��*������M��49�	50r5c��Uc+URR[RS5 g[	U[515(a52U[:Xd)[	U[5(a6UR[:Xa"[UR[R'g[	U[535(a-[U5 SUS3UR[R'g[	U[5(a�[	UR[545(ac[UR5 UR(aSURS3OSURS3nX R[R'g[S[U5S35e)N�"zW/"zUnsupported etag type: z . etag must be str, ETag or None)
rLr�rr�r�r�rrr�rr�rsr�)rNr��	hdr_values   r6r�r��s���=��M�M���d�i�i��.����$�$��(�):��u�d�#�#����x�(?�'/�D�M�M�$�)�)�$�
��s�
#�
#���&�)*�5�'��|�D�M�M�$�)�)�$�
��t�
$�
$��E�K�K��)E�)E�����,�05�
�
�#�e�k�k�]�!�,�Q�u�{�{�m�ST�CU�I�'0�M�M�$�)�)�$��)�$�u�+��71�2��
r5�CONTENT_TYPEc��URceURceSRSURR555nU(aURS-U-nOURnX0RU'g)Nz; c3�4# �UHupUSU3v� M g7f)�=Nr/)�.0�k�vs   r6�	<genexpr>�?StreamResponse._generate_content_type_header.<locals>.<genexpr>�s���M�2L�$�!�a�S��!��:�2L�s�)r�r��join�itemsrL)rNr��paramsr�s    r6r��,StreamResponse._generate_content_type_header�sz���!�!�-�-�-��!�!�-�-�-����M�$�2D�2D�2J�2J�2L�M�M����&�&��-��6�E��&�&�E�&+�
�
�l�#r5�codingc��T# �U[RLagURceURUR[55R'URRURUR5 URR[56RS5 g7frR)r%r.r@r�rLr�CONTENT_ENCODINGr�r=�popallr�)rNr�s  r6�_do_start_compression�$StreamResponse._do_start_compression�s����]�+�+�+���#�#�/�/�/�/5�|�|��
�
�d�+�+�,����/�/��L�L�$�4�4�	57�58	
�
�
���T�0�0�$�7�s�B&B(�requestc��h# �UR(a$URUR5IShv�N gURR[R59S5R
5n[R5H%up4X2;dMURU5IShv�N  g gN{N7f)Nrm)	r>r�rGrrr�ACCEPT_ENCODINGr��CONTENT_CODINGSr�)rNr��accept_encodingr�r�s     r6�_start_compression�!StreamResponse._start_compression�s�����"�"��,�,�T�-D�-D�E�E�E��"�/�/�-�-�d�.B�.B�B�G�M�M�O��,�2�2�4�M�E��'��0�0��8�8�8��5�
F�9�s(�0B2�B.�AB2�B2�$B0�%60B2�0B2c���# �UR(agURbUR$[URUR5UlUR
U5IShv�N$N7frR)rAr@r�methodrErB�_start)rNr�s  r6�prepare�StreamResponse.prepare�sS����>�>�����+��'�'�'�#5�g�n�n�d�k�k�#R�� ��[�[��)�)�)�)�s�A%A.�'A,�(A.c���# �XlUR=o lUR5IShv�N URU5IShv�N UR	5IShv�N U$N7N N617frR)r?r@�_prepare_headers�
_prepare_hook�_write_headers)rNr��writers   r6r��StreamResponse._start�sc����	�(/�(?�(?�?��%��#�#�%�%�%��#�#�D�)�)�)��!�!�#�#�#��
�		&�)�#�s3�,A,�A&�A,�A(�A,�A*� A,�(A,�*A,c��# �URnUceURnUceURnUcURnX0lURnUR62nUR(aSURR5H5nURSS9SSnUR[RU5 M7 UR(aURU5IShv�N UR(acU[:wa$[!SR#UR55eUR$(d#UR'5 SU[R('O�UR*(apUR,UlUR.cRU[:�a5UR$(d#UR'5 SU[R('OUR$(dSnUR$(ap[R0U;a6[3UR4UR65(aU[R0	[R(U;aU[R(	OMUR*(aUR.OUR,S:wa UR9[R:S5 UR9[R<[?55 UR9[R@[B5 [RDU;aEU(aU[F:XaS	U[RD'ggU[:XaS63U[RD'gggGNn7f)Nrm)�headerrz@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}r^Frr�z64keep-alive�close)$r?r@r:rwr�rLrC�values�output�addr�65SET_COOKIEr<r�r;r!r��formatrB�enable_chunking�TRANSFER_ENCODING�
_length_checkr��lengthr�rr�rE�66setdefaultr��DATEr�SERVERr�67CONNECTIONr )rNr�rrwr�rG�cookier�s        r6r�StreamResponse._prepare_headers�s�����)�)���"�"�"��%�%���!�!�!��%�%�68��� �+�+�J�%���/�/���-�-���=�=��-�-�.�.�0���
�
�R�
�0���4�����D�O�O�U�3�1�����)�)�'�2�2�2��=�=��-�'�"�3�39�6�'�/�/�3J����+�+��&�&�(�2;���.�.�/��
�
�
� �/�/�F�M��}�}�$��m�+��3�3��.�.�0�:C��� 6� 6�7���1�1�!&�J��#�#��"�"�g�-�2N�������3�3��D�/�/�0��%�%��0��D�2�2�3��#�1�1�f�m�m�t�7J�7J�q�
P����t�0�0�2L�M����4�9�9�&;�&=�>����4�;�;��8��?�?�'�)���m�+�/;�G�D�O�O�,�,��M�)�+2�����(�*�	*�O
3�s�C%M�'M�(I.Mc��F# �URnUceURnUceURnSUSSUSSURSUR3nURX@R5IShv�N UR(aUR5 ggN'7f)NzHTTP/r�.r� )	r?r@r�rZrf�
write_headersrL�_send_headers_immediately�send_headers)rNr�rr��status_lines     r6r�StreamResponse._write_headerss�����)�)���"�"�"��%�%���!�!�!��/�/���g�a�j�\��7�1�:�,�a����~�Q�t�|�|�n�U���"�"�;�
�
�>�>�>��)�)����!�*�	?�s�A5B!�7B�8(B!�datac��$# �[U[[[45(dS[	U5-5eUR69(a[
S5eURc[
S5eURRU5IShv�N gN7f)N�#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()z$Cannot call write() before prepare())	r��bytes�	bytearray�70memoryviewr�rAr�r@�write�rNr!s  r6r'�StreamResponse.write&s������5�)�Z�0�71�72�	>�0�4��:�=�	>�73��>�>��F�G�G����'��E�F�F��"�"�(�(��.�.�.�s�BB�B�	Bc���# �UR(aS5eURcS5e[R"S[SS9 URR5IShv�N gN7f)NzEOF has already been sent�Response has not been startedz2drain method is deprecated, use await resp.write()r�)�74stacklevel)rAr@r�r�r��drainrSs r6r-�StreamResponse.drain2s_����>�>�>�#>�>�!��#�#�/�P�1P�P�/��
�
�@���	75�76�"�"�(�(�*�*�*�s�A$A.�&A,�'A.c��h# �[U[[[45(dS[	U5-5eUR77(agURcS5eURRU5IShv�N SUlSUlURRUl78SUlgN57f)Nr#r+T)r�r$r%r&r�rAr@�	write_eofr?�output_sizer}r(s  r6r0�StreamResponse.write_eof<s������5�)�Z�0�79�80�	>�0�4��:�=�	>�81��>�>���#�#�/�P�1P�P�/��"�"�,�,�T�2�2�2������	� �0�0�<�<���#���		3�s�A8B2�:B0�;6B2c�$�UR(aSnOSUR(a@URceURRSURRS3nOSnSUR82RSURSUS3$)N�eofrznot prepared�<�>)rArTr?r�r�r�r0rF)rN�infos  r6�__repr__�StreamResponse.__repr__Lsz���>�>��D�
�]�]��9�9�(�(�(��i�i�&�&�'�q������(8��:�D�!�D��4�>�>�*�*�+�1�T�[�[�M��4�&��B�Br5�keyc� �URU$rR�rK�rNr:s  r6�__getitem__�StreamResponse.__getitem__Vs���{�{�3��r5c� �X RU'grRr<)rNr:r�s   r6�__setitem__�StreamResponse.__setitem__Ys�� ���C�r5c��URU	grRr<r=s  r6�__delitem__�StreamResponse.__delitem__\s���K�K��r5c�,�[UR5$rR)�lenrKrSs r6�__len__�StreamResponse.__len___s���4�;�;��r5c�,�[UR5$rR)�iterrKrSs r6�__iter__�StreamResponse.__iter__bs���D�K�K� � r5c�*�[[U55$rR)�hash�idrSs r6�__hash__�StreamResponse.__hash__es���B�t�H�~�r5�otherc��XL$rRr/)rNrSs  r6�__eq__�StreamResponse.__eq__hs83���}�r5c��g)NTr/rSs r6�__bool__�StreamResponse.__bool__ks��r5)r}r;r<r>r=r�rCrArLr:rBr@rfr?rKrZ)rIzOptional[asyncio.Task[None]]rR)rIN)NN)rIzCIMultiDict[str])r�r)rIN�r5)Yr0r1r2r3rr$r%r"�__annotations__rr9r:rr�r;r<r=rpr>r%r?r@rrArBr}rCrrr�r$rrO�propertyrTrWrEr^rbrFrjrMrwrzr~r�r�r�rGr�r�r�r��setterr�r�r�r�r�rr�rr�rr�r�r�r�r�rrr&r'r-r0r8rr>rArDrHr	rLrQ�objectrUrXr4�
__classcell__�r�s@r6r&r&Ls������u�i��0�1�1��M��E�"&�K��$��&��H�d���L�$��+/��8�C�=�/�26����/�6�$(�D�(�=�84!�(�6:�O�X�2�3�:��I�t��*.���$��.��L�'+�H�h�|�$�+� $��85� $�*.�48�
)��)���
�	)�86�,�'�)� ��C� 0�1�
)�87�)�4�B�$�B��B������������������!�T�!��!�������!%�)��)���
�)�88�	)��#��x��}����� �H�T�N� �� �!��!�S�!��!��0�s�0��0�89�(�3�-��4��7;�"&�.���d�M�1�2�3�.��3�-�.�90�	.�*����������"&� $�-1��!%�#'�!%�"&�&*�3+��3+��3+�91�#��3+���
�
3+��%��S��/�*�3+��3+����3+��4�.�3+��#��3+��3�-�3+��d�^�3+�92�3+�r!%��!%�#'�"&�93��94���
�	95�96�97����
98��4�.�99��3�-�100�101�102�:�&���
�&��&����	9�H�S�M�	9�d�	9��	9��$�c�$��$����-�#�-�$�-��-�103���#�����
�^�^�-�X�c�]�-�t�-��-��F�x��(9�(9�:�F��F����!��e�C���0A�0A�3�$F�G�H�!�	
�!��!�&�
104�h�t�n�
105��
106�107�[�[��(�5��s��#3�4������*$(�#4�#4�108,� �109,�	
�110,�1118�-�1128�D�1138�114�*�]�*�x�@T�7U�*��M��6J��?3�B"�115/��e�Y�116�&B� C�117/��118/�+�$�E�$�D�$� C�#�C� �s� �s� �!�s�!�3�!�4�!��s��t�� �� �!�(�3�-�!��#���F��t���$��r5r&c��^�\rSrSr%Sr\\\S'SrSSSSSSSSSS.	S\	S\119S	\\S120\\S\\S\\S
\\S\\121S\\
SS4U4Sjjjr\S\\\\44Sj5r\R&S\	SS4Sj5r\S\\4Sj5r\R&S122\SS4Sj5r\S\\1234Sj5r\R&S\\124SS4Sj5rS!S\SS4U4SjjjrSSS\4U4SjjrS\SS4U4SjjrS rU=r$)"r'ioN�_compressed_bodyFrD)	�bodyrErF�textrGr�r��zlib_executor_size�
zlib_executorrcrErFrdrGr�r�rerfrIc	�>�UbUb[S5eUc[5n125O[U5n126UbSU;a[S5eUb�[RU127;aU(dU(a[S5eO�[	U[1285(d[
S[U5-5eUcSnUcSnUS-U-U129[R'URU5nSnOF[RU130;aUcUb[S5eO UbUbUSU--
nXj[R'[TU])X#U131S	9 UbX@lOXlX�l
X�lg)132Nz&body and text are not allowed togetherr�z,charset must not be in content_type argumentzPpassing both Content-Type header and content_type or charset params is forbidden�text argument must be str (%r)�133text/plain�utf-8z134; charset=)rErFrH)rsrrr�r�r�r�r��encoder�rOrdrc�_zlib_executor_size�_zlib_executor)rNrcrErFrdrGr�r�rerf�real_headersr�s           �r6rO�Response.__init__tsk������ 0��E�F�F��?�-8�]�L�&�w�/�L��#�	�\�(A��K�L�L���� � �L�0��7�$�'���$+�"�$��,�,�#�$D�t�D�z�$Q�R�R��'�#/�L��?�%�G�2>��2M�PW�2W��T�.�.�/��{�{�7�+����
�
�
�,�
.��'�7�+>� �#���,?��
%��"���w� 6�6��.:��*�*�+�
����\��R����I��I�#5� �+�r5c��UR$rR)r9rSs r6rc�
Response.body�s���z�z�r5c��UcSUlO�[U[[45(aXlO�[R135R
U5=UlnURn[RU;aURU[R'UR(a.URR5Hup4X2;dMXBU'M SUlg![Ra [S[U5-5ef=f)NzUnsupported body type %r)r9r�r$r%r�PAYLOAD_REGISTRYrr�LookupErrorrsr�rLrr�r�rGr�rb)rNrcrGr:r�s     r6rcrq�s����<��D�J�
��u�i�0�
1�
1��J�
J�$+�$<�$<�$@�$@��$F�F��136�T��m�m�G�� � ��/�-1�->�->���)�)�*��|�|�"&�,�,�"4�"4�"6�J�C��)�',���#7�!%�����&�&�
J� �!;�d�4�j�!H�I�I�
J�s�&C�,Dc�z�URcgURRUR=(d S5$)Nrj)r9�decoder�rSs r6rd�
Response.text�s/���:�:����z�z� � ����!8��9�9r5c���Ub([U[5(dS[U5-5eURS:XaSUlURcSUlURUR5UlSUlg)Nrhr�rirj)r�r�r�r�r�rkr9rb)rNrds  r6rdrw�sy���|�z��#� 137� 138�	9�+�d�4�j�8�	9�139���� :�:� ,�D���<�<��"�D�L��[�[����.��140� $��r5c�x�UR(ag[RUR;a&[	UR[R5$UR141b[
UR1425$[UR[5(agURb[
UR5$g)Nr)143r;rr�rLrprbrGr�r9r"rSs r6r��Response.content_length�s����=�=�����$�-�-�/��t�}�}�T�%8�%8�9�:�:�� � �,��t�,�,�-�-�
��144�145�G�
,�
,��
�Z�Z�
#��t�z�z�?�"�r5r�c��[S5e)Nz#Content length is set automatically)r�r�s  r6r�rz�s���@�A�Ar5r!c��># �UR(agURc
URnOURnU(aSU<35eURceURceUbUR146(a[TU]5IShv�N g[UR[5(afURRUR5IShv�N URR5IShv�N [TU]5IShv�N g[TU][[U55IShv�N gN�NeNEN1N
7f)Nzdata arg is not supported, got )rArbr9r?r@rBr�r0r�r"r'r	r
r$)rNr!rcr�s   �r6r0�Response.write_eofs�����>�>��� � �(�48�J�J�D��(�(�D��C�:�4�(�C�C�x��y�y�$�$�$��#�#�/�/�/��<�4�3�3��'�#�%�%�%�
��147�148�G�
,�
,��*�*�"�"�4�#7�#7�8�8�8��*�*�"�"�$�$�$��'�#�%�%�%��'�#�D���$5�6�6�6�

&�8�$�%�6�s[�BE�E�AE�E�!E�E�E�E�%E�<E149�=E�E�E�E�150Er�r)c���># �[RUR;aA[URUR1515(aUR[R	O�UR(d�[UR[5(a@URR=nb&[U5UR[R'O�UR(a[UR5OSnUS:wd.UR152S:waDUR[R;a&[U5UR[R'[TU]=U5IShv�N$N7f)N�0i0)rr�rLrr�rEr;r�r9r"�sizer�rG�
METH_HEAD_ALLr�r�)rNr�r��body_lenr�s    �r6r��Response._starts��������$�-�-�/�+�G�N�N�D�K�K�H�H��M�M�$�"5�"5�6������$�*�*�g�.�.� �J�J�O�O�+�D�8�9<�T��D�M�M�$�"5�"5�6��.2�j�j�3�t�z�z�?�c���s�?��K�K�3�&�7�>�>��AS�AS�+S�9<�X��D�M�M�$�"5�"5�6��W�^�G�,�,�,�,�s�E$E.�'E,�(E.r�c��># �UR(d[UR[5(a[TU]U5IShv�N$U[RLag[URURURS9nURceURcJ[UR5[:�a-[R"S[UR5S35 UR!UR5IShv�NUR#5-UlURUR&[(R*'[-[UR$55UR&[(R.'gGNBN~7f)N)�encoding�max_sync_chunk_size�executorz2Synchronous compression of large response bodies (z� bytes) might block the async event loop. Consider providing a custom value to zlib_executor_size/zlib_executor response properties or disabling compression on it.)r;r�r9r"r�r�r%r.rr�rlrmrG�LARGE_BODY_SIZEr�r��compress�flushrbrLrr�r�r�)rNr��153compressorr�s   �r6r��Response._do_start_compression&s3�����=�=�J�t�z�z�7�;�;���6�v�>�>�>��]�+�+�+��$��\�\� $� 8� 8��(�(�154�155�156�z�z�%�%�%��#�#�+��D�J�J��/�0Q��M�M����157�158�O�$�%T�T�
��%�%�d�j�j�1�1�J�4D�4D�4F�F�	
��06�|�|��
�
�d�+�+�,�-0��T�5J�5J�1K�-L��
�
�d�)�)�*�-?�&
2�s&�AF
�F�CF
�F�
A<F
�F
)r9rbrmrlrcr�r�rdrZ)r0r1r2r3rbrr$r[rrrpr�r$rrOr\rr"rcr]rdr�r0rr�r%r�r4r_r`s@r6r'r'os����(,��h�u�o�,� %��159�� $�"�*.�&*�!%�,0�,0�?,��?,��	?,�160��
�?,��s�m�
?,��,�'�?,��s�m�?,��#��?,�%�S�M�?,� ��)�?,�161�?,�?,�B��h�u�U�G�^�4�5����162�[�[�%��%��%��%�2�:�h�s�m�:��:�163�[�[�%��%��%��%�����
����$���B�H�S�M�B�d�B��B�7�E�7�D�7�7�&-�M�-�6J�-�$M�-�M�D�M�Mr5r'rDzapplication/json)rdrcrErFrGr��dumpsr!rdrcrErFrGr�r�rIc	�r�U[La!U(dU(a[S5eU"U5n[UUUUUUS9$)Nz3only one of data, text, or body should be specified)rdrcrErFrGr�)rrsr')r!rdrcrErFrGr�r�s        r6r(r(AsE���8���4��R�S�S���;�D��
�
����!�
�r5)F�asyncio�collections.abc�collectionsr��enum�jsonr�r�r��concurrent.futuresr�httpr�http.cookiesr�typingrrrr	r164rrr
�	multidictrrrmrr�abcr�compression_utilsr�helpersrrrrrrrrrrrr r!r"�typedefsr#r$r��phraserqr��__all__�web_requestr)r��	BaseClass�Enumr%r�r&r'r�r$rpr()�http_statusr�s00r6�<module>r�s�����������'��%�	�	�	�(��%�-����@�?��/�KU�V�:�K�#�#�[�%7�%7�7�:�V����165J���(��s�C�x�(�I����.�.�I��D�I�I��7D�D�m�F�<�<��'�m�D��`�Y��`�FOM�~�OM�f��� �� �&*�*�����166
���3�-���5�/�	�167
��
�S�M�
��l�
#���������kW��2Es� E-�E2
codekingpro/portable-devtools · Team Ai