HEX
Server: LiteSpeed
System: Linux s1049.use1.mysecurecloudhost.com 4.18.0-477.27.2.lve.el8.x86_64 #1 SMP Wed Oct 11 12:32:56 UTC 2023 x86_64
User: xedaptot (3356)
PHP: 8.3.31
Disabled: NONE
$ pwd: /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/
Upload Files
File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/payload.cpython-310.pyc
o

;j��	@sHUddlZddlZddlZddlZddlZddlZddlZddlZddlm	Z	m
Z
ddlmZddl
mZddlmZmZmZmZmZddlmZddlmZdd	lmZdd
lmZmZmZmZmZm Z ddl!m"Z"ddl#m$Z$dd
l%m&Z&m'Z'm(Z(dZ)dZ*ee+e,d<e-�Z.e-ej/de,d<Gdd�de0�Z1Gdd�de2ej3�Z4dedededdfdd�Z5e4j6d�de7dded e4ddfd!d"�Z8Gd#d$�d$�Z9e7dZ:e;e:efZ<Gd%d&�d&�Z=Gd'd�de	�Z>Gd(d)�d)e>�Z?Gd*d+�d+e?�Z@Gd,d-�d-e@�ZAGd.d/�d/e>�ZBGd0d1�d1eB�ZCGd2d3�d3eB�ZDGd4d5�d5eB�ZEGd6d7�d7e?�ZFGd8d9�d9e?�ZGe�r?dd:lmHZHmIZIeIeJZKeHeJZLndd:lmHZHmIZIeIZKeHZLGd;d<�d<e>�ZMGd=d>�d>eM�ZNe=�ZOeO�Pe?eJeQeRf�eO�Pe@e2�eO�PeAejS�eO�PeCejT�eO�PeDejU�eO�PeEejVejWf�eO�PeBejX�eO�PeNe$�eOjPeMeHe4jYd�dS)?�N)�ABC�abstractmethod)�Iterable)�chain)�IO�
TYPE_CHECKING�Any�Final�TextIO)�CIMultiDict�)�hdrs)�AbstractStreamWriter)�	_SENTINEL�DEFAULT_CHUNK_SIZE�content_disposition_header�guess_filename�parse_mimetype�sentinel��_safe_header)�StreamReader)�JSONBytesEncoder�JSONEncoder�_CIMultiDict)�PAYLOAD_REGISTRY�get_payload�payload_type�Payload�BytesPayload�
StringPayload�
IOBasePayload�BytesIOPayload�BufferedReaderPayload�
TextIOPayload�StringIOPayload�JsonPayload�JsonBytesPayload�AsyncIterablePayloadi�TOO_LARGE_BYTES_BODY�_CLOSE_FUTURESc@seZdZdZdS)�LookupErrorz@Raised when no payload factory is found for the given data type.N)�__name__�
__module__�__qualname__�__doc__�r0r0�C/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/payload.pyr+3sr+c@seZdZdZdZdZdS)�Order�normal�	try_first�try_lastN)r,r-r.r3r4r5r0r0r0r1r27sr2�data�args�kwargs�returnrcOstj|g|�Ri|��S�N)r�get)r6r7r8r0r0r1r=sr��order�factory�typer=cCstj|||d�dS�Nr<)r�register)r>r?r=r0r0r1�register_payloadAsrBc@sDeZdZejd�dededdfdd�Zded	ded	fd
d�ZdS)rr<r?r=r9NcCs||_||_dSr:)r?r=)�selfr?r=r0r0r1�__init__Hs
zpayload_type.__init__r>rcCst||j|jd�|Sr@)rBr?r=)rCr>r0r0r1�__call__Lszpayload_type.__call__)	r,r-r.r2r3rrDr?rEr0r0r0r1rGsrc@sdeZdZdZdZddd�Zed�ded	ed
ddedd
f
dd�Ze	j
d�dedede	ddfdd�ZdS)�PayloadRegistryzZPayload registry.

    note: we need zope.interface for more efficient adapter search
    ��_first�_normal�_last�_normal_lookupr9NcCsg|_g|_g|_i|_dSr:rG�rCr0r0r1rD]s
zPayloadRegistry.__init__)�_CHAINr6r7rMz!type[chain[_PayloadRegistryItem]]r8rcOs�|jr|jD]\}}t||�r||g|�Ri|��Sq|j�t|��}r2||g|�Ri|��St|t�r9|S||j|j�D]\}}t||�rV||g|�Ri|��Sq@t��r:)	rH�
isinstancerKr;r?rrIrJr+)rCr6rMr7r8r>�type_Zlookup_factoryr0r0r1r;cs
�

�zPayloadRegistry.getr<r>r?r=cCs�|tjur|j�||f�dS|tjur4|j�||f�t|t�r-|D]}||j|<q#dS||j|<dS|tj	urC|j
�||f�dStd|����)NzUnsupported order )r2r4rH�appendr3rIrNrrKr5rJ�
ValueError)rCr>r?r=�tr0r0r1rAzs


�
zPayloadRegistry.register�r9N)
r,r-r.r/�	__slots__rDrrr;r2r3�PayloadTyperAr0r0r0r1rFUs4

�����
������rFc@s�eZdZUdZeed<dZedBed<dZe	ed<dZ
e	ed<deddfded	e
eeefBeeeefBdBd
edBeBdedBdedBd
eddfdd�ZededBfdd��ZededBfdd��Zede
fdd��Zedefdd��ZededBfdd��Zedefdd��Zede	fdd��Zede	fdd ��Z	!	"d9d#ed$e	d%ed&eddf
d'd(�Zed:ded*edefd+d,��Zed-e ddfd.d/��Z!d-e d0edBddfd1d2�Z"d:ded*edefd3d4�Z#d;d5d6�Z$d;d7d8�Z%dS)<r�application/octet-stream�_default_content_typeN�_sizeF�	_consumed�
_autoclose�value�headers�content_type�filename�encodingr8r9cKs�||_||_t�|_||_|tur|dur||jtj<n-|jdurBtj	dkr*t
j}nt
j}||j�d}|dur;|j
}||jtj<n|j
|jtj<|rS|j�|�dSdS)N)��
r)�	_encoding�	_filenamer�_headers�_valuerr
�CONTENT_TYPE�sys�version_info�	mimetypesZguess_file_typeZ
guess_typerW�update)rCr[r\r]r^r_r8Zguesserr0r0r1rD�s$

�zPayload.__init__cC�|jS)z�Size of the payload in bytes.

        Returns the number of bytes that will be transmitted when the payload
        is written. For string payloads, this is the size after encoding to bytes,
        not the length of the string.
        �rXrLr0r0r1�size��zPayload.sizecCrk)zFilename of the payload.)rcrLr0r0r1r^��zPayload.filenamecCrk)zCustom item headers)rdrLr0r0r1r\�rozPayload.headerscCs$d�dd�|j��D���d�dS)N�css,�|]\}}t|�dt|�dVqdS)z: z
Nr)�.0�k�vr0r0r1�	<genexpr>�s
��
�z*Payload._binary_headers.<locals>.<genexpr>�utf-8s
)�joinr\�items�encoderLr0r0r1�_binary_headers�s
���zPayload._binary_headerscCrk)zPayload encoding)rbrLr0r0r1r_�rozPayload.encodingcCs|jtjS)zContent type)rdr
rfrLr0r0r1r]�szPayload.content_typecCrk)z;Whether the payload has been consumed and cannot be reused.)rYrLr0r0r1�consumed�rozPayload.consumedcCrk)z�
        Whether the payload can close itself automatically.

        Returns True if the payload has no file handles or resources that need
        explicit closing. If False, callers must await close() to release resources.
        )rZrLr0r0r1�	autoclose�rnzPayload.autocloseTru�disptype�quote_fields�_charset�paramscKs"t|f||d�|��|jtj<dS)z$Sets ``Content-Disposition`` header.)r}r~N)rrdr
�CONTENT_DISPOSITION)rCr|r}r~rr0r0r1�set_content_disposition�s���zPayload.set_content_disposition�strict�errorscC�dS)z�
        Return string representation of the value.

        This is named decode() to allow compatibility with bytes objects.
        Nr0�rCr_r�r0r0r1�decode��zPayload.decode�writerc���dS)a�
        Write payload to the writer stream.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing

        This is a legacy method that writes the entire payload without length constraints.

        Important:
            For new implementations, use write_with_length() instead of this method.
            This method is maintained for backwards compatibility and will eventually
            delegate to write_with_length(writer, None) in all implementations.

        All payload subclasses must override this method for backwards compatibility,
        but new code should use write_with_length for more flexibility and control.

        Nr0�rCr�r0r0r1�write��z
Payload.write�content_lengthc�s�|�|�IdHdS)a�
        Write payload with a specific content length constraint.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing
            content_length: Maximum number of bytes to write (None for unlimited)

        This method allows writing payload content with a specific length constraint,
        which is particularly useful for HTTP responses with Content-Length header.

        Note:
            This is the base implementation that provides backwards compatibility
            for subclasses that don't override this method. Specific payload types
            should override this method to implement proper length-constrained writing.

        N)r��rCr�r�r0r0r1�write_with_lengths�zPayload.write_with_lengthc�s�|jp|}|�||��|�S)z�
        Return bytes representation of the value.

        This is a convenience method that calls decode() and encodes the result
        to bytes using the specified encoding.
        )rbr�rx)rCr_r��actual_encodingr0r0r1�as_bytes*s�
zPayload.as_bytescCr�)a�
        Async safe synchronous close operations for backwards compatibility.

        This method exists only for backwards compatibility with code that
        needs to clean up payloads synchronously. In the future, we will
        drop this method and only support the async close() method.

        WARNING: This method must be safe to call from within the event loop
        without blocking. Subclasses should not perform any blocking I/O here.

        WARNING: This method must be called from within an event loop for
        certain payload types (e.g., IOBasePayload). Calling it outside an
        event loop may raise RuntimeError.
        Nr0rLr0r0r1�_close5r�zPayload._closec���|��dS)a\
        Close the payload if it holds any resources.

        IMPORTANT: This method must not await anything that might not finish
        immediately, as it may be called during cleanup/cancellation. Schedule
        any long-running operations without awaiting them.

        In the future, this will be the only close method supported.
        N�r�rLr0r0r1�closeGs�
z
Payload.close)Tru�rur�rS)&r,r-r.rW�str�__annotations__rX�intrY�boolrZrrr�dictr�tuplerrD�propertyrmr^r\�bytesryr_r]rzr{r�rr�rr�r�r�r�r�r0r0r0r1r�s�
��"�
���	�

�		�����
���
�
cs�eZdZUeed<dZdeeBeBdededdf�fdd	�Z	dde
d
e
de
fdd�Zdde
d
e
defdd�Zde
ddfdd�Zde
dedBddfdd�Z�ZS)rreTr[r7r8r9Ncs�d|vrd|d<t�j|g|�Ri|��t|t�r|j|_nt|ttf�r,t|�|_n	t	dt
|�����|jtkrJd|i}tj
dtfi|��dSdS)Nr]rVz%value argument must be byte-ish, not �sourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)�superrDrN�
memoryview�nbytesrXr��	bytearray�len�	TypeErrorr?r)�warnings�warn�ResourceWarning�rCr[r7r8��	__class__r0r1rDYs"


�
��zBytesPayload.__init__rur�r_r�cCs|j�||�Sr:)rer�r�r0r0r1r�rszBytesPayload.decodec�s�|jS)z�
        Return bytes representation of the value.

        This method returns the raw bytes content of the payload.
        It is equivalent to accessing the _value attribute directly.
        )rer�r0r0r1r�us�zBytesPayload.as_bytesr�c�s�|�|j�IdHdS)a�
        Write the entire bytes payload to the writer stream.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing

        This method writes the entire bytes content without any length constraint.

        Note:
            For new implementations that need length control, use write_with_length().
            This method is maintained for backwards compatibility and is equivalent
            to write_with_length(writer, None).

        N�r�rer�r0r0r1r�~��zBytesPayload.writer�c�s>�|dur|�|jd|��IdHdS|�|j�IdHdS)a�
        Write bytes payload with a specific content length constraint.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing
            content_length: Maximum number of bytes to write (None for unlimited)

        This method writes either the entire byte sequence or a slice of it
        up to the specified content_length. For BytesPayload, this operation
        is performed efficiently using array slicing.

        Nr�r�r0r0r1r��s�zBytesPayload.write_with_lengthr�)r,r-r.r�r�rZr�r�rrDr�r�r�rr�r�r��
__classcell__r0r0r�r1rTs,

����	���rc
sFeZdZddd�dedededBdedBdeddf�fd	d
�Z�ZS)r N�r_r]r[r7r_r]r8r9csp|dur|dur
d}d}nt|�}|j�dd�}n
|dur!d|}|}t�j|�|�g|�R||d�|��dS)Nru�text/plain; charset=utf-8�charset�text/plain; charset=%sr�)r�
parametersr;r�rDrx)rCr[r_r]r7r8Z
real_encoding�mimetyper�r0r1rD�s&	���
�zStringPayload.__init__)r,r-r.r�rrDr�r0r0r�r1r �s �������r cs2eZdZdeedededdf�fdd�Z�ZS)r%r[r7r8r9Nc�"t�j|��g|�Ri|��dSr:)r�rD�readr�r�r0r1rD��"zStringIOPayload.__init__)r,r-r.rr�rrDr�r0r0r�r1r%�s*r%csNeZdZUejed<dZedBed<	d-dee	de
de	de	d	df
�fd
d�
Zd.dd
�ZdedBd	e
edBeffdd�ZdedBd	efdd�Zed	edBfdd��Zded	dfdd�ZdededBd	dfdd�ZdedBdededBd	efdd�Zd.dd �Zd.d!d"�Zd/d%e
d&e
d	e
fd'd(�Zd	efd)d*�Zd/d%e
d&e
d	efd+d,�Z�ZS)0r!reN�_start_position�
attachmentr[�dispositionr7r8r9csld|vr
t|�|d<t�j|g|�Ri|��|jdur0|dur2tj|jvr4|j||jd�dSdSdSdS)Nr^)r^)rr�rDrcr
r�r\r�)rCr[r�r7r8r�r0r1rD�s�zIOBasePayload.__init__c	Csp|jdurz	|j��|_WdSttfyd|_YdSwz
|j�|j�WdSttfy7d|_YdSw)z:Set or restore the start position of the file-like object.NT)r�re�tell�OSError�AttributeErrorrY�seekrLr0r0r1�_set_or_restore_start_position�s
���z,IOBasePayload._set_or_restore_start_position�remaining_content_lencCs.|��|j}||j�tt|pt|pt��fS)a�
        Read the file-like object and return both its total size and the first chunk.

        Args:
            remaining_content_len: Optional limit on how many bytes to read in this operation.
                If None, DEFAULT_CHUNK_SIZE will be used as the default chunk size.

        Returns:
            A tuple containing:
            - The total size of the remaining unread content (None if size cannot be determined)
            - The first chunk of bytes read from the file object

        This method is optimized to perform both size calculation and initial read
        in a single operation, which is executed in a single executor job to minimize
        context switches and file operations when streaming content.

        )r�rmrer��minr)rCr�rmr0r0r1�_read_and_available_len�s��z%IOBasePayload._read_and_available_lencCs|j�|pt�S)a

        Read a chunk of data from the file-like object.

        Args:
            remaining_content_len: Optional maximum number of bytes to read.
                If None, DEFAULT_CHUNK_SIZE will be used as the default chunk size.

        Returns:
            A chunk of bytes read from the file object, respecting the
            remaining_content_len limit if specified.

        This method is used for subsequent reads during streaming after
        the initial _read_and_available_len call has been made.

        )rer�r)rCr�r0r0r1�_readszIOBasePayload._readc	CsJz|jdur|j��|_t�|j���j|jWSttfy$YdSw)ad
        Size of the payload in bytes.

        Returns the total size of the payload content from the initial position.
        This ensures consistent Content-Length for requests, including 307/308 redirects
        where the same payload instance is reused.

        Returns None if the size cannot be determined (e.g., for unseekable streams).
        N)	r�rer��os�fstat�fileno�st_sizer�r�rLr0r0r1rms
�zIOBasePayload.sizer�c���|�|d�IdHdS)a0
        Write the entire file-like payload to the writer stream.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing

        This method writes the entire file content without any length constraint.
        It delegates to write_with_length() with no length limit for implementation
        consistency.

        Note:
            For new implementations that need length control, use write_with_length() directly.
            This method is maintained for backwards compatibility with existing code.

        N�r�r�r0r0r1r�4s�zIOBasePayload.writer�c	�s��t��}d}|}|�d|j|�IdH\}}|r^t|�}|dur)|�|�IdHn|�|d|��IdH||8}||7}|�|||�rFdS|�d|j|durTtt	|�nt	�IdH}|sdSdS)a�
        Write file-like payload with a specific content length constraint.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing
            content_length: Maximum number of bytes to write (None for unlimited)

        This method implements optimized streaming of file content with length constraints:

        1. File reading is performed in a thread pool to avoid blocking the event loop
        2. Content is read and written in chunks to maintain memory efficiency
        3. Writing stops when either:
           - All available file content has been written (when size is known)
           - The specified content_length has been reached
        4. File resources are properly closed even if the operation is cancelled

        The implementation carefully handles both known-size and unknown-size payloads,
        as well as constrained and unconstrained content lengths.

        rN)
�asyncio�get_running_loop�run_in_executorr�r�r��_should_stop_writingr�r�r)	rCr�r��loop�total_written_lenr��
available_len�chunkZ	chunk_lenr0r0r1r�Fs4���
�
��zIOBasePayload.write_with_lengthr�r�cCs |dur||kp|duo|dkS)a3
        Determine if we should stop writing data.

        Args:
            available_len: Known size of the payload if available (None if unknown)
            total_written_len: Number of bytes already written
            remaining_content_len: Remaining bytes to be written for content-length limited responses

        Returns:
            True if we should stop writing data, based on either:
            - Having written all available data (when size is known)
            - Having written all requested content (when content-length is specified)

        Nrr0)rCr�r�r�r0r0r1r��s�z"IOBasePayload._should_stop_writingcCsB|jrdSd|_t��}|�d|jj�}t�|�|�tj	�dS)aL
        Async safe synchronous close operations for backwards compatibility.

        This method exists only for backwards
        compatibility. Use the async close() method instead.

        WARNING: This method MUST be called from within an event loop.
        Calling it outside an event loop will raise RuntimeError.
        NT)
rYr�r�r�rer�r*�addZadd_done_callback�remove)rCr�Zclose_futurer0r0r1r��s
zIOBasePayload._closec�r�)a
        Close the payload if it holds any resources.

        IMPORTANT: This method must not await anything that might not finish
        immediately, as it may be called during cleanup/cancellation. Schedule
        any long-running operations without awaiting them.
        Nr�rLr0r0r1r��s�zIOBasePayload.closerur�r_r�cCs|���||�S�z�
        Return string representation of the value.

        WARNING: This method does blocking I/O and should not be called in the event loop.
        )�	_read_allr�r�r0r0r1r��szIOBasePayload.decodecCs|��d�|j���S)zARead the entire file-like object and return its content as bytes.�)r�rvre�	readlinesrLr0r0r1r��szIOBasePayload._read_allc�s�t��}|�d|j�IdHS)a!
        Return bytes representation of the value.

        This method reads the entire file content and returns it as bytes.
        It is equivalent to reading the file-like object directly.
        The file reading is performed in an executor to avoid blocking the event loop.
        N)r�r�r�r�)rCr_r�r�r0r0r1r��s�zIOBasePayload.as_bytes)r�rSr�)r,r-r.�io�IOBaser�r�r�rrr�rDr�r�r�r�r�r�rmrr�r�r�r�r�r�r�r�r�r�r0r0r�r1r!�s\

������
�
���
�=���
�


 r!c
s�eZdZUejed<ddd�dedededBdedBded	df�fd
d�Z	de
dBd	ee
dBeffd
d�Z
de
dBd	efdd�Zddeded	efdd�Zddeded	efdd�Z�ZS)r$reNr�r[r7r_r]r8r9csf|dur|dur
d}d}nt|�}|j�dd�}n|dur!d|}t�j|g|�R||d�|��dS)Nrur�r�r��r]r_)rr�r;r�rD)rCr[r_r]r7r8r�r�r0r1rD�s$	���
�zTextIOPayload.__init__r�cCsJ|��|j}|j�tt|pt|pt��}||jr |�|j�fS|��fS)a�
        Read the text file-like object and return both its total size and the first chunk.

        Args:
            remaining_content_len: Optional limit on how many bytes to read in this operation.
                If None, DEFAULT_CHUNK_SIZE will be used as the default chunk size.

        Returns:
            A tuple containing:
            - The total size of the remaining unread content (None if size cannot be determined)
            - The first chunk of bytes read from the file object, encoded using the payload's encoding

        This method is optimized to perform both size calculation and initial read
        in a single operation, which is executed in a single executor job to minimize
        context switches and file operations when streaming content.

        Note:
            TextIOPayload handles encoding of the text content before writing it
            to the stream. If no encoding is specified, UTF-8 is used as the default.

        )r�rmrer�r�rrbrx)rCr�rmr�r0r0r1r��s�� z%TextIOPayload._read_and_available_lencCs*|j�|pt�}|jr|�|j�S|��S)a�
        Read a chunk of data from the text file-like object.

        Args:
            remaining_content_len: Optional maximum number of bytes to read.
                If None, DEFAULT_CHUNK_SIZE will be used as the default chunk size.

        Returns:
            A chunk of bytes read from the file object and encoded using the payload's
            encoding. The data is automatically converted from text to bytes.

        This method is used for subsequent reads during streaming after
        the initial _read_and_available_len call has been made. It properly
        handles text encoding, converting the text content to bytes using
        the specified encoding (or UTF-8 if none was provided).

        )rer�rrbrx)rCr�r�r0r0r1r�szTextIOPayload._readrur�r�cCs|��|j��Sr��r�rer�r�r0r0r1r�-s
zTextIOPayload.decodec�s<�t��}�jp	|�dtf���fdd�}|�d|�IdHS)a%
        Return bytes representation of the value.

        This method reads the entire text file content and returns it as bytes.
        It encodes the text content using the specified encoding.
        The file reading is performed in an executor to avoid blocking the event loop.
        r9cs����j������Sr:)r�rer�rxr0�r�r�rCr0r1�_read_and_encodeCsz0TextIOPayload.as_bytes.<locals>._read_and_encodeN)r�r�rbr�r�)rCr_r�r�r�r0r�r1r�6s
�
zTextIOPayload.as_bytesr�)r,r-r.r��
TextIOBaser�r
rr�rDr�r�r�r�r�r�r�r�r0r0r�r1r$�s2

��������
�# 	r$cs�eZdZUejed<eed<dZdejdededdf�fd	d
�Z	e
defdd��Zddededefdd�Z
deddfdd�ZdededBddfdd�Zddededefdd�Zddd�Z�ZS)r"rerXTr[r7r8r9Ncs8t�j|g|�Ri|��t|j���|j��|_dSr:)r�rDr�re�	getbufferr�rXr�r�r0r1rDPszBytesIOPayload.__init__cCrk)z�Size of the payload in bytes.

        Returns the number of bytes in the BytesIO buffer that will be transmitted.
        This is calculated once during initialization for efficiency.
        rlrLr0r0r1rmUszBytesIOPayload.sizerur�r_r�cC�|��|j���||�Sr:�r�rer�r�r�r0r0r1r�^�zBytesIOPayload.decoder�c�s�|�|d�IdHSr:r�r�r0r0r1r�bs�zBytesIOPayload.writer�c�s��|��d}|}|j�t�}rP|dkrt�d�IdH|dur*|�|�IdHn|�|d|��IdH|t|�8}|dkrBdS|d7}|j�t�}sdSdS)a:
        Write BytesIO payload with a specific content length constraint.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing
            content_length: Maximum number of bytes to write (None for unlimited)

        This implementation is specifically optimized for BytesIO objects:

        1. Reads content in chunks to maintain memory efficiency
        2. Yields control back to the event loop periodically to prevent blocking
           when dealing with large BytesIO objects
        3. Respects content_length constraints when specified
        4. Properly cleans up by closing the BytesIO object when done or on error

        The periodic yielding to the event loop is important for maintaining
        responsiveness when processing large in-memory buffers.

        rNr)r�rer�rr��sleepr�r�)rCr�r�Z
loop_count�remaining_bytesr�r0r0r1r�es��z BytesIOPayload.write_with_lengthc�s�|��|j��S)z�
        Return bytes representation of the value.

        This method reads the entire BytesIO content and returns it as bytes.
        It is equivalent to accessing the _value attribute directly.
        r�r�r0r0r1r��s�
zBytesIOPayload.as_bytesc�r�)z�
        Close the BytesIO payload.

        This does nothing since BytesIO is in-memory and does not require explicit closing.
        Nr0rLr0r0r1r��r�zBytesIOPayload.closer�rS)r,r-r.r��BytesIOr�r�rZrrDr�rmr�r�rr�r�r�r�r�r�r0r0r�r1r"Ks$

 ��
�)
r"c@s0eZdZUejed<d
dededefdd�Zd	S)r#rerur�r_r�r9cCr�r:r�r�r0r0r1r��r�zBufferedReaderPayload.decodeNr�)r,r-r.r��BufferedIOBaser�r�r�r0r0r0r1r#�s

r#csDeZdZddejfdedededededed	d
f�fdd�
Z�Z	S)
r&ru�application/jsonr[r_r]�dumpsr7r8r9Ncs.t�j||��|�g|�R||d�|��dS)Nr�)r�rDrx)rCr[r_r]r�r7r8r�r0r1rD�s
���
�zJsonPayload.__init__)
r,r-r.�jsonr�rr�rrDr�r0r0r�r1r&�s&��������r&c
s>eZdZdZ	ddedededededd	f�fd
d�
Z�ZS)
r'z�JSON payload for encoders that return bytes directly.

    Use this when your JSON encoder (like orjson) returns bytes
    instead of str, avoiding the encode/decode overhead.
    r�r[r�r]r7r8r9Ncs&t�j||�g|�Rd|i|��dS)Nr])r�rD)rCr[r�r]r7r8r�r0r1rD�s���
�zJsonBytesPayload.__init__)r�)	r,r-r.r/rrr�rDr�r0r0r�r1r'�s 
�������r')�
AsyncIterable�
AsyncIteratorcs�eZdZUdZedBed<eed<dZee	dBed<dZ
dededed	df�fd
d�Zde
d	dfd
d�Zde
dedBd	dfdd�Zddeded	efdd�Zddeded	e	fdd�Z�ZS)r(N�_iterre�_cached_chunksTr[r7r8r9csTt|t�stdt|�����d|vrd|d<t�j|g|�Ri|��|��|_dS)NzIvalue argument must support collections.abc.AsyncIterable interface, got r]rV)rNr�r�r?r�rD�	__aiter__r�r�r�r0r1rD�s
��zAsyncIterablePayload.__init__r�c�r�)a�
        Write the entire async iterable payload to the writer stream.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing

        This method iterates through the async iterable and writes each chunk
        to the writer without any length constraint.

        Note:
            For new implementations that need length control, use write_with_length() directly.
            This method is maintained for backwards compatibility with existing code.

        Nr�r�r0r0r1r��r�zAsyncIterablePayload.writer�c�s��|jdur6|}|jD](}|dur|�|�IdHq|dkr1|�|d|��IdH|t|�8}qdSdS|jdur=dS|}z-	t|j�IdH}|durV|�|�IdHn|dkrl|�|d|��IdH|t|�8}qAty|d|_d|_YdSw)ay
        Write async iterable payload with a specific content length constraint.

        Args:
            writer: An AbstractStreamWriter instance that handles the actual writing
            content_length: Maximum number of bytes to write (None for unlimited)

        This implementation handles streaming of async iterable content with length constraints:

        1. If cached chunks are available, writes from them
        2. Otherwise iterates through the async iterable one chunk at a time
        3. Respects content_length constraints when specified
        4. Does NOT generate cache - that's done by as_bytes()

        NrT)r�r�r�r��anext�StopAsyncIterationrY)rCr�r�r�r�r0r0r1r�s6�


��z&AsyncIterablePayload.write_with_lengthrur�r_r�cCs&|jdurd�|j��||�Std��)zFDecode the payload content as a string if cached chunks are available.Nr�z=Unable to decode - content not cached. Call as_bytes() first.)r�rvr�r�r�r0r0r1r�@s
zAsyncIterablePayload.decodec�s`�|jdurd�|j�S|jdurdSg}|j2z3dHW}|�|�q6d|_||_d�|�S)z�
        Return bytes representation of the value.

        This method reads the entire async iterable content and returns it as bytes.
        It generates and caches the chunks for future reuse.
        Nr�)r�rvr�rP)rCr_r��chunksr�r0r0r1r�Fs�

�
zAsyncIterablePayload.as_bytesr�)r,r-r.r��_AsyncIteratorr��_AsyncIterabler��listr�rZrrDrr�r�r�r�r�r�r�r0r0r�r1r(�s 
��
�8 r(cs.eZdZdedededdf�fdd�Z�ZS)�StreamReaderPayloadr[r7r8r9Ncr�r:)r�rDZiter_anyr�r�r0r1rDcr�zStreamReaderPayload.__init__)r,r-r.rrrDr�r0r0r�r1r�bs&r�)Zr��enumr�r�rir�rgr��abcrr�collections.abcr�	itertoolsr�typingrrrr	r
Z	multidictrrpr
rZhelpersrrrrrrZhttp_writerrZstreamsrZtypedefsrrr�__all__r)r�r��setr*ZFuture�	Exceptionr+r��Enumr2rr3r?rBrrUr�Z_PayloadRegistryItemrFrrr r%r!r$r"r#r&r'r�r�r�r�r�r(r�rrAr�r��StringIOr�r��BufferedReader�BufferedRandomr�r5r0r0r0r1�<module>s�
 ����
�
7IPvU	

@ Telegram