← back to Atmos Game

assets/gen/.venv/lib/python3.12/site-packages/httpx/__pycache__/_content.cpython-312.pyc

56 lines

�

c�bj����ddlmZddlZddlZddlmZddlmZm	Z	m
Z
mZmZm
Z
ddlmZddlmZmZddlmZdd	lmZmZmZmZmZmZdd
lmZmZdgZGd�dee�Z Gd
�de�Z!Gd�de�Z"Gd�dee�Z#				dd�Z$				dd�Z%								dd�Z&dd�Z'dd�Z(d d�Z)					d!											d"d�Z*				d#									d$d�Z+y)%�)�annotationsN)�dumps)�Any�
AsyncIterable�
AsyncIterator�Iterable�Iterator�Mapping)�	urlencode�)�StreamClosed�StreamConsumed)�MultipartStream)�AsyncByteStream�RequestContent�RequestData�RequestFiles�ResponseContent�SyncByteStream)�peek_filelike_length�primitive_value_to_str�
ByteStreamc�$�eZdZdd�Zdd�Zdd�Zy)rc��||_y�N��_stream��self�streams  �e/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpx/_content.py�__init__zByteStream.__init__ s	�����c#�(K�|j��y�wrr�rs r!�__iter__zByteStream.__iter__#s�����l�l��s�c�*K�|j���y�wrrr%s r!�	__aiter__zByteStream.__aiter__&s�����l�l��s�N)r �bytes�return�None�r*zIterator[bytes]�r*zAsyncIterator[bytes])�__name__�
__module__�__qualname__r"r&r(�r#r!rrs����r#c� �eZdZdZdd�Zdd�Zy)�IteratorByteStream�c�T�||_d|_tj|�|_y�NF)r�_is_stream_consumed�inspect�isgenerator�
_is_generatorrs  r!r"zIteratorByteStream.__init__-s$�����#(�� �$�0�0��8��r#c#�^K�|jr|jr
t��d|_t|jd�rU|jj|j�}|r-|��|jj|j�}|r�,yy|jD]}|���y�w)NT�read)r7r:r�hasattrrr<�
CHUNK_SIZE�r�chunk�parts   r!r&zIteratorByteStream.__iter__2s������#�#��(:�(:� �"�"�#'�� ��4�<�<��(��L�L�%�%�d�o�o�6�E�������)�)�$�/�/�:���
�����
�%�s�BB-�B-N)r zIterable[bytes]r*r+r,)r.r/r0r>r"r&r1r#r!r3r3*s���J�9�
r#r3c� �eZdZdZdd�Zdd�Zy)�AsyncIteratorByteStreamr4c�T�||_d|_tj|�|_yr6)rr7r8�
isasyncgenr:rs  r!r"z AsyncIteratorByteStream.__init__Fs$�����#(�� �$�/�/��7��r#c�K�|jr|jr
t��d|_t|jd�rf|jj|j��d{���}|r6|���|jj|j��d{���}|r�5yy|j23d{���}|����7�X7�&7�6y�w)NT�aread)r7r:rr=rrGr>r?s   r!r(z!AsyncIteratorByteStream.__aiter__Ks������#�#��(:�(:� �"�"�#'�� ��4�<�<��)��,�,�,�,�T�_�_�=�=�E����"�l�l�0�0����A�A���
#�l�l�
�d��
�>��B��
��l�sN�A(C�*C�+3C�C�C�&C�4C	�8C�9C	�<C�C�C	�	CN)r zAsyncIterable[bytes]r*r+r-)r.r/r0r>r"r(r1r#r!rCrCCs���J�8�
r#rCc� �eZdZdZdd�Zdd�Zy)�UnattachedStreamz�
    If a request or response is serialized using pickle, then it is no longer
    attached to a stream for I/O purposes. Any stream operations should result
    in `httpx.StreamClosed`.
    c��t��r�r
r%s r!r&zUnattachedStream.__iter__cs
���n�r#c�K�t���wrrKr%s r!r(zUnattachedStream.__aiter__fs�����n��s�
Nr,r-)r.r/r0�__doc__r&r(r1r#r!rIrI\s����r#rIc���t|ttf�rLt|t�r|jd�n|}t	|�}|r
dt|�ini}|t|�fSt|t�r<t|t�s,t|�}|�ddi}n
dt|�i}|t|�fSt|t�rddi}|t|�fStdt|�����)N�utf-8�Content-LengthzTransfer-Encoding�chunkedzUnexpected type for 'content', )�
isinstancer)�str�encode�lenrr�dictrr3rrC�	TypeError�type)�content�body�content_length�headers�content_length_or_nones     r!�encode_contentr^ks����'�E�3�<�(�*4�W�c�*B�w�~�~�g�&����T���=A�#�S��%8�9�r���
�4�(�(�(�	�G�X�	&�z�'�4�/H�
"6�g�!>��!�)�*�I�6�G�'��-C�)D�E�G��*�7�3�3�3�	�G�]�	+�&�	�2���/��8�8�8�
�5�d�7�m�5F�G�
H�Hr#c
��g}|j�D]b\}}t|ttf�r+|j	|D�cgc]}|t|�f��c}��G|j
|t|�f��dt|d��jd�}tt|��}d}||d�}|t|�fScc}w)NT)�doseqrOz!application/x-www-form-urlencoded�rPzContent-Type)�itemsrR�list�tuple�extendr�appendrrTrSrUr)	�data�
plain_data�key�value�itemrZr[�content_typer\s	         r!�encode_urlencoded_datarm�s����J��j�j�l�
��U��e�d�E�]�+����u�U�u�t��%;�D�%A�B�u�U�V����s�$:�5�$A�B�C�	#�
�Z�t�,�3�3�G�<�D���T��^�N�6�L�!/��N�G��J�t�$�$�$��Vs�B<
c�F�t|||��}|j�}||fS)N)rg�files�boundary)r�get_headers)rgrorp�	multipartr\s     r!�encode_multipart_datars�s+�� �T���J�I��#�#�%�G��I��r#c�t�|jd�}tt|��}d}||d�}|t|�fS)NrOztext/plain; charset=utf-8ra�rTrSrUr)�textrZr[rlr\s     r!�encode_textrw�s<���;�;�w��D���T��^�N�.�L�!/��N�G��J�t�$�$�$r#c�t�|jd�}tt|��}d}||d�}|t|�fS)NrOztext/html; charset=utf-8raru)�htmlrZr[rlr\s     r!�encode_htmlrz�s<���;�;�w��D���T��^�N�-�L�!/��N�G��J�t�$�$�$r#c��t|ddd��jd�}tt|��}d}||d�}|t	|�fS)NF)�,�:)�ensure_ascii�
separators�	allow_nanrOzapplication/jsonra)�
json_dumpsrTrSrUr)�jsonrZr[rlr\s     r!�encode_jsonr��sO����5�Z�5���f�W�o�	���T��^�N�%�L�!/��N�G��J�t�$�$�$r#c��|�9t|t�s)d}tj|td��t|�S|�t|�S|rt
|xsi||�S|rt|�S|�t|�Sitd�fS)z�
    Handles encoding the given `content`, `data`, `files`, and `json`,
    returning a two-tuple of (<headers>, <stream>).
    z5Use 'content=<...>' to upload raw bytes/text content.�)�
stacklevelr#)
rRr
�warnings�warn�DeprecationWarningr^rsrmr�r)rYrgror�rp�messages      r!�encode_requestr��s�����
�4�� 9�J���
�
�g�1�a�@��d�#�#����g�&�&�	�$�T�Z�R���A�A�	
�%�d�+�+�	
�	��4� � �
�z�#���r#c��|�t|�S|�t|�S|�t|�S|�t|�Sit	d�fS)zc
    Handles encoding the given `content`, returning a two-tuple of
    (<headers>, <stream>).
    r#)r^rwrzr�r)rYrvryr�s    r!�encode_responser��sW�����g�&�&�	
�	��4� � �	
�	��4� � �	
�	��4� � �
�z�#���r#)rYz4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r*�7tuple[dict[str, str], SyncByteStream | AsyncByteStream])rgrr*�!tuple[dict[str, str], ByteStream])rgrrorrp�bytes | Noner*z&tuple[dict[str, str], MultipartStream])rvrSr*r�)ryrSr*r�)r�rr*r�)NNNNN)rYzRequestContent | NonergzRequestData | NonerozRequestFiles | Noner��
Any | Nonerpr�r*r�)NNNN)
rYzResponseContent | Nonerv�
str | Noneryr�r�r�r*r�),�
__future__rr8r�r�rr��typingrrrrr	r
�urllib.parser�_exceptionsr
r�
_multipartr�_typesrrrrrr�_utilsrr�__all__rr3rCrIr^rmrsrwrzr�r�r�r1r#r!�<module>r�sb��"���$���#�5�'���A��.����.�����2�o��2����I�
A�I�<�I�:
%�
�
%�&�
%� �
��*��6B��+��%�%�%�&*�#�!%��!� �
"� �
� �� ��	 �
� �=�
 �H'+����	�
#��
�����	�
=�r#