Ë
|
¸^i
|
¤ ã óX U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
|
Z
|
d dl m Z d dl mZ d dlmZmZmZmZmZmZmZmZmZmZmZmZ d dl m Z ddl m Z dd lm Z dd
|
l!m"Z"m#Z#m$Z$m%Z%m&Z& dd l'm(Z( dd l)m*Z*m+Z+ d Z,dZ-ee. e/d< dZ0ee. e/d< e1« Z2ee jf d e/d< G d de4« Z5 G d de6ejn « Z8dedededdfd Z9e8jt d d ed d ed e8ddfd!Z; G d" d#« Z<ed Z=ee=ef Z> G d$ d%« Z? G d& de « Z@ G d' d(e@« ZA G d) d*eA« ZB G d+ d,eB« ZC G d- d.e@« ZD G d/ d0eD« ZE G d1 d2eD« ZF G d3 d4eD« ZG G d5 d6eA« ZHerd d7lmIZImJZJ eJeK ZLeIeK ZMn d d7l mIZImJZJ eJZLeIZM G d8 d9e@« ZN G d: d;eN« ZO e?« ZPePj£ eAeKeReSf« ePj£ eBe6« ePj£ eCej¨ « ePj£ eEejª « ePj£ eFej¬ « ePj£ eGej® ej° f« ePj£ eDej² « ePj£ eOe(« ePj£ eNeIe8j´ ¬ « y)<é N)ÚABCÚabstractmethod)ÚIterable)Úchain) ÚIOÚ TYPE_CHECKINGÚAnyÚDictÚFinalÚListÚOptionalÚSetÚTextIOÚTupleÚTypeÚUnion)Ú CIMultiDicté )Úhdrs)ÚAbstractStreamWriter)Ú _SENTINELÚcontent_disposition_headerÚguess_filenameÚparse_mimetypeÚsentinel)Ú StreamReader)Ú JSONEncoderÚ _CIMultiDict) ÚPAYLOAD_REGISTRYÚ get_payloadÚ payload_typeÚPayloadÚ BytesPayloadÚ StringPayloadÚ IOBasePayloadÚBytesIOPayloadÚBufferedReaderPayloadÚ TextIOPayloadÚStringIOPayloadÚ JsonPayloadÚAsyncIterablePayloadi ÚTOO_LARGE_BYTES_BODYi Ú READ_SIZEÚ_CLOSE_FUTURESc ó e Zd ZdZy)Ú LookupErrorz@Raised when no payload factory is found for the given data type.N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__© ó õb H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/payload.pyr0 r0 > s ÚJr6 r0 c ó e Zd ZdZdZdZy)ÚOrderÚnormalÚ try_firstÚtry_lastN)r1 r2 r3 r: r; r< r5 r6 r7 r9 r9 B s Ø FØIØHr6 r9 ÚdataÚargsÚkwargsÚreturnr" c ó4 t j | g|¢i |¤S ©N)r Úget)r= r> r? s r7 r r H s Ü × Ñ Ð 6 tÒ 6¨vÑ 6Ð6r6 ©ÚorderÚfactoryÚtyperE c ó4 t j | ||¬« y ©NrD )r Úregister)rF rG rE s r7 Úregister_payloadrK L s ô × Ñ g t°5Ð Õ9r6 c óV e Zd Zej ddededdfdZded ded fd Zy)
|
r! rD rG rE r@ Nc ó || _ || _ y rB )rG rE )ÚselfrG rE s r7 Ú__init__zpayload_type.__init__S s Ø Ø
|
r6 rF r" c óJ t || j | j ¬« |S rI )rK rG rE )rN rF s r7 Ú__call__zpayload_type.__call__W s Ü $§)¡)°4·:±:Õ>Ør6 ) r1 r2 r3 r9 r: r rO r rQ r5 r6 r7 r! r! R s> Ø49·L±Lò Sð ¨Eð ÀTó ð Y¡ð °D¸±Oô r6 r! c óp e Zd ZdZdZddZeddeded d
|
d edd f
|
d Ze j dde dede ddfdZ y)ÚPayloadRegistryzZPayload registry.
|
|
note: we need zope.interface for more efficient adapter search
|
©Ú_firstÚ_normalÚ_lastÚ_normal_lookupr@ Nc ó< g | _ g | _ g | _ i | _ y rB rT ©rN s r7 rO zPayloadRegistry.__init__h s Ø24 Ø35 Ø13
|
Ø68Õr6 )Ú_CHAINr= r> r[ z!Type[chain[_PayloadRegistryItem]]r? r" c ó | j r.| j D ] \ }}t ||« s ||g|¢i |¤c S | j j t |« « x}r ||g|¢i |¤S t |t
|
« r|S || j | j « D ] \ }}t ||« s ||g|¢i |¤c S t « rB ) rU Ú
|
isinstancerX rC rG r" rV rW r0 )rN r= r[ r> r? rF Útype_Úlookup_factorys r7 rC zPayloadRegistry.getn sÒ ð ;;Ø"&§+¡+ò :Ü d EÕ*Ù" 4Ð9¨$Ò9°&Ñ9Ò9ð :ð "× 0Ñ 0× 4Ñ 4´T¸$³ZÓ @Ð @>Ð @Ù! $Ð8¨Ò8°Ñ8Ð 8ä dGÔ $ØKá $ T§\¡\°4·:±:Ó >ò 6NGUÜ$ Õ&Ù tÐ5 dÒ5¨fÑ5Ò5ð 6ô mÐr6 rD rF rG rE c óª |t j u r | j j ||f« y |t j u rT| j
|
j ||f« t |t « r|D ] }|| j |< y || j |< y |t j u r | j j ||f« y t d|« )NzUnsupported order ) r9 r; rU Úappendr: rV r] r rX r< rW Ú
|
ValueError)rN rF rG rE Úts r7 rJ zPayloadRegistry.register
s¸ ð EOOÑ #Ø KK× Ñ ¨Õ /Ø ellÑ "Ø LL× Ñ ¨$ Ô 0Ü$¤Ô)Ø ò 5AØ-4D×'Ñ'¨Ò*ñ5ð -4×#Ñ# DÒ)Ø ennÑ $Ø JJ× Ñ w¨oÕ .ä Ð 1°%°Ð ;Ó<Ð <r6 ©r@ N) r1 r2 r3 r4 Ú __slots__rO r r rC r9 r: Ú PayloadTyperJ r5 r6 r7 rS rS ` s~ ñð
|
AIó9ð 7<ò àð ð ð ð 4ð ð
|
ð ð
|
ó ð0 BGÇ Á ò=Ø"ð=Ø*-ð=Ø9>ð=à ô=r6 rS c ó e Zd ZU dZeed< dZee ed< dZ e
|
ed< dZ e
|
ed< de ddfde d eeeeeef eeeef f d
|
eedef d ee d ee d e ddfdZedee fd« Zedee fd« Zedefd« Zedefd« Zedee fd« Zedefd« Z ede
|
fd« Z ede
|
fd« Z d&dede
|
dede ddf
|
d Z e d'd ed edefd « Z!e d e"ddfd « Z#d e"d!ee ddfd"Z$d'd ed edefd#Z%d(d$Z&d(d%Z'y))r" úapplication/octet-streamÚ_default_content_typeNÚ_sizeFÚ _consumedÚ
|
_autocloseÚvalueÚheadersÚ content_typeÚfilenameÚencodingr? r@ c ó( || _ || _ t « | _ || _ |t
|
ur | || j t j < n¨| j ut j dk\ rt j }nt j } || j « d }| | j }|| j t j < n'| j | j t j < |r | j j |« y y )N)é é r )Ú _encodingÚ _filenamer Ú_headersÚ_valuer r Ú CONTENT_TYPEÚsysÚ version_infoÚ mimetypesÚguess_file_typeÚ
|
guess_typeri Úupdate)rN rm rn ro rp rq r? Úguessers r7 rO zPayload.__init__ sÝ ð "Ø!Ü&1£m Ø Ø xÑ '¨LÐ,DØ/;DMM$×+Ñ+Ò ,Ø ^^Ð 'Ü× Ñ 7Ò*Ü#×3Ñ3ä#×.Ñ.Ù" 4§>¡>Ó2°1Ñ5LØÐ#Ø #× 9Ñ 9 Ø/;DMM$×+Ñ+Ò ,à/3×/IÑ/IDMM$×+Ñ+Ñ ,Ù Ø MM× Ñ Õ )ð r6 c ó | j S )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.
|
©rj rZ s r7 Úsizez Payload.size½ s ð zzÐr6 c ó | j S )zFilename of the payload.)rv rZ s r7 rp zPayload.filenameÇ ó ð ~~Ð r6 c ó | j S )zCustom item headers)rw rZ s r7 rn zPayload.headersÌ s ð }}Ð r6 c ó¼ dj | j j « D cg c] \ }}|dz |z dz c}}« j d« dz S c c}}w )NÚ z: z
|
úutf-8s
|
)Újoinrn ÚitemsÚencode)rN ÚkÚvs r7 Ú_binary_headerszPayload._binary_headersÑ sY ð GG°t·|±|×7IÑ7IÓ7K×L©t¨q°!QX \ FÓ*ÓLÓ M× TÑ TØó ð ñ ð
|
ùÛLs ©A
|
c ó | j S )zPayload encoding)ru rZ s r7 rq zPayload.encodingÚ r
r6 c ó< | j t j S )z Content type)rw r ry rZ s r7 ro zPayload.content_typeß s ð }}T× .Ñ .Ñ/Ð/r6 c ó | j S )z;Whether the payload has been consumed and cannot be reused.)rk rZ s r7 ÚconsumedzPayload.consumedä r
r6 c ó | j S )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.
|
)rl rZ s r7 Ú autoclosezPayload.autocloseé s ð Ð r6 ÚdisptypeÚ quote_fieldsÚ_charsetÚparamsc óX t |f||d|¤| j t j < y)z$Sets ``Content-Disposition`` header.)r r N)r rw r ÚCONTENT_DISPOSITION)rN r r r r s r7 Úset_content_dispositionz Payload.set_content_dispositionó s3 ô 3MØ ð3
|
Ø#/¸(ñ3
|
ØFLñ3
|
d×.Ñ.Ò/r6 Úerrorsc ó y)z
|
Return string representation of the value.
|
|
This is named decode() to allow compatibility with bytes objects.
|
Nr5 ©rN rq r s r7 ÚdecodezPayload.decodeÿ ó r6 Úwriterc ó K yw)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.
|
|
Nr5 ©rN r¢ s r7 Úwritez Payload.write ó è ø ùó Úcontent_lengthc óB K | j |« d{ y7 w)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¥ ©rN r¢ r¨ s r7 Úwrite_with_lengthzPayload.write_with_length s è ø ð* jjÓ × Ò ús c ól K | j xs |}| j ||« j |« S w)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.
|
)ru r r )rN rq r Úactual_encodings r7 Úas_byteszPayload.as_bytes4 s2 è ø ð ..Ò4¨HØ{{?¨FÓ3×:Ñ:¸?ÓKÐKùs 24c ó y)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.
|
Nr5 rZ s r7 Ú_closezPayload._close? r¡ r6 c ó, K | j « yw)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° rZ s r7 Úclosez Payload.closeQ s è ø ð ùó )Tr ©r Ústrictrd )(r1 r2 r3 ri ÚstrÚ__annotations__rj r Úintrk Úboolrl r r r r r
|
r r r rO Úpropertyr rp rn Úbytesr rq ro r r r r r r r¥ r« r® r° r³ r5 r6 r7 r" r" sz
à!;Ð3Ó;Ø E8C=Ó ØItÓØ JÓ ð Ø4<Ø"&Ø"&ñ *àð *ð Ø , S¨# X¡°¸¸sÀC¸x¹ Ñ0IÐIÑ Jñ
|
ð *ð C yÐ 0Ñ1ð *ð 3-ð *ð 3-ð *ð ð *ð
|
ó *ð> ðhsmò ó ðð ð ( 3-ò ó ð ð ð ò ó ð ð ð
|
ò
|
ó ð
|
ð ð ( 3-ò ó ð ð ð0cò 0ó ð0ð ð $ò ó ð ð ð 4ò ó ð ð "Ø ñ
|
|
àð
|
|
ð ð
|
|
ð ð
|
|
ð
|
ð
|
|
ð
|
ó
|
|
ð ñ sð °cð Èò ó ð ð ð Ð"6ð ¸4ò ó ð ð*!Ø*ð!Ø<DÀS¹Mð!à ó!ñ. L sð L¸cð LÐQVó Ló ô$
|
r6 c ó¢ e Zd ZU eed< dZdeeeef de de ddf fd Z
|
dd e d
|
e de fd Z dd e d
|
e defd Z d eddfdZd edee ddfdZ xZS )r# rx Trm r> r? r@ Nc ód d|vrd|d< t | |g|¢i |¤ t |t « r|j | _ n>t |t t f« rt |« | _ nt dt |« « | j
|
t kD r d| i}t j dt fi |¤ y y )Nro rh z%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)ÚsuperrO r] Ú
|
memoryviewÚnbytesrj r¼ Ú bytearrayÚlenÚ TypeErrorrG r, ÚwarningsÚwarnÚResourceWarning©rN rm r> r? Ú __class__s r7 rO zBytesPayload.__init__c s° ø ð Ñ 'Ø%?F>Ñ "ä ÑÐ0 Ò0¨Ò0ä eZÔ (Ø DJÜ ¤¤yÐ 1Ô 2Ü UDJäÐ CÄDÈÃKÀ?Ð SÓTÐ Tà ::Ô,Ò ,Ø Ð%FÜ MMð,ô ñ ð
|
ó ð -r6 rq r c ó: | j j ||« S rB )rx r r s r7 r zBytesPayload.decode| s Ø{{×!Ñ! (¨FÓ3Ð3r6 c ó" K | j S w)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.
|
)rx r s r7 r® zBytesPayload.as_bytes s è ø ð {{Ðùs r¢ c óV K |j | j « d{ y7 w)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¥ rx r¤ s r7 r¥ zBytesPayload.write s è ø ð ll4;;Ó'×'Ò'ús )¡'¢)r¨ c ó¬ K |'|j | j d| « d{ y|j | j « d{ y7 )7 w)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ª s r7 r« z BytesPayload.write_with_length sJ è ø ð Ð %Ø,,t{{¨?¨NÐ ;Ó<× <Ñ <à,,t{{Ó+× +Ñ +ð =øà +ús! $A¦A§#AÁ
|
AÁ AÁArµ )r1 r2 r3 r¼ r¸ rl r rà rÁ r rO r· r r® r r¥ r r¹ r« Ú __classcell__©rÊ s @r7 r# r# ^ s¨ ø
Ø MàJðØ5 )¨ZÐ7Ñ8ðØADðØPSðà õñ24sð 4°cð 4Èó 4ñ sð ¸cð ÐQVó ð(Ð"6ð (¸4ó (ð",Ø*ð,Ø<DÀS¹Mð,à ÷,r6 r# c óL e Zd Zddddededee dee deddf fd Z xZS )
|
r$ N©rq ro rm r> rq ro r? r@ c óÄ |/|d}d}n1t |« }|j j dd« }n |d|z }|}t | |j |« g|¢||d|¤ y )Nr útext/plain; charset=utf-8Úcharsetútext/plain; charset=%srÓ )r Ú
|
parametersrC rÀ rO r ) rN rm rq ro r> r? Ú real_encodingÚmimetyperÊ s r7 rO zStringPayload.__init__¯ s ø ð Ð ØÐ#Ø ' Ø : ä)¨,Ó7Ø (× 3Ñ 3× 7Ñ 7¸ À7Ó K àÐ#Ø 7¸(Ñ B Ø $Mä ÑØ LL Ó 'ð
|
ð ñ
|
à"Ø%ñ
|
ð
|
ó
|
r6 )r1 r2 r3 r· r r rO rÐ rÑ s @r7 r$ r$ ® sW ø ð
|
#'Ø&*ò
|
àð
|
ð ð
|
ð 3-ð
|
ð
|
smð
|
ð ð
|
ð
|
÷
|
ñ
|
r6 r$ c ó6 e Zd Zdee dededdf fd Z xZS )r) rm r> r? r@ Nc óH t | |j « g|¢i |¤ y rB )rÀ rO ÚreadrÉ s r7 rO zStringIOPayload.__init__Î s ø Ü Ñ Ð7¨Ò7°Ó7r6 )r1 r2 r3 r r· r rO rÐ rÑ s @r7 r) r) Í s- ø ð8b gð 8¨cð 8¸Sð 8ÀT÷ 8ñ 8r6 r) c óh e Zd ZU ej ed< dZee ed< d de e
|
de de
|
de
|
ddf
|
fd Z d d
|
Z d ee deee ef fd Zd ee defd Zedee fd« ZdeddfdZdedee ddfdZdee ded ee defdZd dZd dZd de de de fdZdefdZ d de de defd Z xZ S ) r% rx NÚ_start_positionrm Ú dispositionr> r? r@ c óä d|vrt |« |d< t | |g|¢i |¤ | j >|;t j
|
| j vr | j || j ¬« y y y y )Nrp )rp )r rÀ rO rv r r rn r )rN rm rà r> r? rÊ s r7 rO zIOBasePayload.__init__Ø sy ø ð VÑ #Ü!/°Ó!6F:Ñ ä ÑÐ0 Ò0¨Ò0à >>Ð %¨+Ð*AÜ×'Ñ'¨t¯|©|Ñ;Ø×,Ñ,¨[À4Ç>Á>Ð,ÕRð <ð +BÐ %r6 c ó | j ! | j j « | _ y | j j | j « y# t t f$ r
|
d| _ Y yw xY w# t t f$ r
|
d| _ Y yw xY w)z:Set or restore the start position of the file-like object.NT)rß rx ÚtellÚOSErrorÚAttributeErrorrk ÚseekrZ s r7 Ú _set_or_restore_start_positionz,IOBasePayload._set_or_restore_start_positionä s à × Ñ Ð 'ð &Ø'+§{¡{×'7Ñ'7Ó'9Ô$ð ð "Ø KK× Ñ T× 1Ñ 1Õ 2øô ^Ð,ò &Ø!%Ø ð &ûô
|
Ð(ò "à !DNð "ús" A ¯%A1 ÁA.Á-A.Á1B
|
 B
|
Úremaining_content_lenc ó² | j « | j }|| j j t t
|
|xs t
|
|xs t
|
« « 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, READ_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ç r rx rÝ Úminr- )rN rè r s r7 Ú_read_and_available_lenz%IOBasePayload._read_and_available_lenò sN ð( ×+Ñ+Ô-ØyyØT[[×%Ñ%Ü 4Ò,¤9Ð.CÒ.PÄyÓ Qó
|
ð
|
ð
|
r6 c óH | j j |xs t « 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, READ_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.
|
|
)rx rÝ r- )rN rè s r7 Ú_readzIOBasePayload._read s ð {{× Ñ Ð 5Ò B¼ÓCÐCr6 c ó | j | j j « | _ t j | j j « « j | j z
|
S # t t f$ r Y yw xY w)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ß rx rã ÚosÚfstatÚfilenoÚst_sizerå rä rZ s r7 r zIOBasePayload.size sp ð ð ×#Ñ#Ð+Ø'+§{¡{×'7Ñ'7Ó'9Ô$ô 88DKK× .Ñ .Ó 0Ó1×9Ñ9¸D×<PÑ<PÑPÐ PøÜ ¤Ð(ò Ùð ús A.A1 Á1BÂBr¢ c óD K | j |d« d{ y7 w)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¤ s r7 r¥ zIOBasePayload.write: s è ø ð ×$Ñ$ V¨TÓ2×2Ò2úó r¨ c óà K t j « }d}|}|j d| j |« d{ \ }}|r t |« }||j |« d{ n!|j |d| « d{ ||z }||z }| j |||« ry|j d| j |t t |« nt « d{ }|ryy7 ª7 7 f7 w)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.
|
|
r N)
|
ÚasyncioÚget_running_loopÚrun_in_executorrë rÄ r¥ Ú_should_stop_writingrí rê r- ) rN r¢ r¨ ÚloopÚtotal_written_lenrè Ú available_lenÚchunkÚ chunk_lens r7 r« z IOBasePayload.write_with_lengthL s è ø ô. ×'Ñ'Ó)Ø ÐØ .Ð ð &*×%9Ñ%9Ø $×.Ñ.Ð0Eó&
|
÷
|
Ñ uñ ÜE
|
Ið %Ð,Ø ll 5Ó)×)Ñ)à ll 5Ð)?Ð*?Ð#@ÓA×AÐAØ%¨Ñ2Ð%à Ñ *Ð ð ×(Ñ(Ø Ð 0Ð2Gôð ð ×.Ñ.ØØ
|
|
ð -Ð8ô Ð#8Ô9ä"ó ÷ Eô' ð
|
øð *øàAøðúsL 9C.»C&¼*C.Á&C(Á' C.ÂC*ÂAC.Ã C,Ã C.Ã$C.Ã(C.Ã*C.Ã,C.rý rü c ó2 |duxr ||k\ xs |duxr |dk S )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)
|
|
Nr r5 )rN rý rü rè s r7 rú z"IOBasePayload._should_stop_writing s4 ð( TÐ)ÒPÐ.?À=Ñ.Pò
|
Ø !¨Ð -Ò LÐ2GÈ1Ñ2Lð
|
r6 c ó | j ryd| _ t j « }|j d| j j
|
« }t j |« |j t j « y)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)
|
rk r÷ rø rù rx r³ r. ÚaddÚadd_done_callbackÚremove)rN rû Ú close_futures r7 r° zIOBasePayload._close¡ sc ð >>Ø Ø ä×'Ñ'Ó)Ø×+Ñ+¨D°$·+±+×2CÑ2CÓD ô ×Ñ<Ô(Ø×&Ñ&¤~×'<Ñ'<Õ=r6 c ó, K | j « yw)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² rZ s r7 r³ zIOBasePayload.close· s è ø ð ùr´ rq r c óB | j « j ||« 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 s r7 r zIOBasePayload.decodeÁ s ð ~~Ó ×&Ñ& x°Ó8Ð8r6 c ót | j « dj | j j « « S )zARead the entire file-like object and return its content as bytes.r6 )rç r rx Ú readlinesrZ s r7 r zIOBasePayload._read_allÉ s* à ×+Ñ+Ô-àxx ×-Ñ-Ó/Ó0Ð0r6 c ó~ K t j « }|j d| j « d{ S 7 w)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 )rN rq r rû s r7 r® zIOBasePayload.as_bytesÏ s3 è ø ô ×'Ñ'Ó)Ø×)Ñ)¨$°·±Ó?×?Ð?Ð?ús 4=¶;·=)Ú
|
attachmentrd rµ ) r1 r2 r3 ÚioÚIOBaser¸ rß r r¹ r r r· rO rç r r¼ rë rí r» r r r¥ r« rº rú r° r³ r r r® rÐ rÑ s @r7 r% r% Ò st ø
Ø IIÓà%)OXc]Ó)ð 2>ñ
|
SØWð
|
SØ+.ð
|
SØFIð
|
SØUXð
|
Sà õ
|
Só "ð
|
Ø%-¨c¡]ð
|
à x}eÐ#Ñ $ó
|
ð4D¨8°C©=ð D¸Uó Dð$ ðhsmò ó ðð63Ð"6ð 3¸4ó 3ð$;Ø*ð;Ø<DÀS¹Mð;à ó;ðz
|
à }ð
|
ð ð
|
ð (¨}ð
|
ð
|
|
ó
|
ó0>ó,ñ9sð 9°cð 9Èó 9ð15ó 1ñ @ sð @¸cð @ÐQV÷ @r6 r% c óÔ e Zd ZU ej ed< ddddededee dee ded df fd
|
Z
|
d ee d e ee e f fd Zd ee d e fd Zdde de d e fdZdde de d e fdZ xZS )r( rx NrÓ rm r> rq ro r? r@ c ó¢ |/|d}d}n/t |« }|j j dd« }n|d|z }t | |g|¢||d|¤ y )Nr rÕ rÖ r× ©ro rq )r rØ rC rÀ rO )rN rm rq ro r> r? rÚ rÊ s r7 rO zTextIOPayload.__init__ß s| ø ð Ð ØÐ#Ø"Ø : ä)¨,Ó7Ø#×.Ñ.×2Ñ2°9¸gÓFàÐ#Ø 7¸(Ñ B ä ÑØ ð
|
ð ñ
|
à%Ø ñ
|
ð
|
ó
|
r6 rè c ó" | j « | j }| j j t t
|
|xs t
|
|xs t
|
« « }|| j r |j | j « fS |j « 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, READ_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ç r rx rÝ rê r- ru r )rN rè r rþ s r7 rë z%TextIOPayload._read_and_available_lenû sr ð0 ×+Ñ+Ô-ØyyØ × Ñ Ü 4Ò,¤9Ð.CÒ.PÄyÓ Qó
|
ð °T·^²^U\\ $§.¡.Ó1ÐWÐWÈÏ É Ë ÐWÐWr6 c ó¶ | j j |xs t « }| j r|j | j « S |j « 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, READ_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).
|
|
)rx rÝ r- ru r )rN rè rþ s r7 rí zTextIOPayload._read sB ð$ × Ñ Ð!6Ò!C¼)ÓDØ/3¯~ª~u||DNNÓ+ÐQÀ5Ç<Á<Ã>ÐQr6 r c óV | j « | j j « S r ©rç rx rÝ r s r7 r zTextIOPayload.decode/ s# ð ×+Ñ+Ô-Ø{{× Ñ Ó!Ð!r6 c ó¬ K t j « } j xs |dt f fd }|j d|« d{ S 7 w)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.
|
r@ c óx j « j j « j « S rB )rç rx rÝ r )r r rN s r7 Ú_read_and_encodez0TextIOPayload.as_bytes.<locals>._read_and_encodeE s/ ø Ø × /Ñ /Ô 1à;;×#Ñ#Ó%×,Ñ,¨_¸fÓEÐ Er6 N)r÷ rø ru r¼ rù )rN rq r rû r r s ` ` @r7 r® zTextIOPayload.as_bytes8 sQ úè ø ô ×'Ñ'Ó)ð ..Ò4¨Hð F¤%÷ Fð
|
×)Ñ)¨$Ð0@ÓA×AÐAÐAús
AAÁ AÁArµ )r1 r2 r3 r Ú
|
TextIOBaser¸ r r r r· rO r¹ r r¼ rë rí r r® rÐ rÑ s @r7 r( r( Û sÙ ø
Ø MMÓð #'Ø&*ò
|
àð
|
ð ð
|
ð 3-ð
|
ð
|
smð
|
ð ð
|
ð
|
õ
|
ð8 XØ%-¨c¡]ð Xà x}eÐ#Ñ $ó Xð>R¨8°C©=ð R¸Uó Rñ*"sð "°cð "Èó "ñB sð B¸cð BÐQV÷ Br6 r( c óæ e Zd ZU ej ed< eed< dZdej dededdf fd Z e
|
defd
|
« Z dd e d e de fd Z deddfdZdedee ddfdZdd e d e defdZddZ xZS )r& rx rj Trm r> r? r@ Nc ó² t | |g|¢i |¤ t | j j « « | j j « z
|
| _ y rB )rÀ rO rÄ rx Ú getbufferrã rj rÉ s r7 rO zBytesIOPayload.__init__R sE ø Ü ÑÐ0 Ò0¨Ò0ä×.Ñ.Ó0Ó1°D·K±K×4DÑ4DÓ4FÑF
|
r6 c ó | j S )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.
|
r rZ s r7 r zBytesIOPayload.sizeW s ð zzÐr6 rq r c óv | j « | j j « j ||« S rB ©rç rx rÝ r r s r7 r zBytesIOPayload.decode` ó. Ø ×+Ñ+Ô-Ø{{× Ñ Ó!×(Ñ(¨°6Ó:Ð:r6 r¢ c óB K | j |d « d { S 7 wrB rô r¤ s r7 r¥ zBytesIOPayload.writed s è ø Ø×+Ñ+¨F°DÓ9×9Ð9Ð9ús r¨ c ó® K | j « d}|}| j j t « x}r|dkD r t j
|
d« d{ ||j |« d{ n0|j |d| « d{ |t |« z }|dk ry|dz }| j j t « x}ryy7 y7 `7 Ew)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.
|
|
r Nr )rç rx rÝ r- r÷ Úsleepr¥ rÄ )rN r¢ r¨ Ú
|
loop_countÚremaining_bytesrþ s r7 r« z BytesIOPayload.write_with_lengthg sÐ è ø ð, ×+Ñ+Ô-Ø
|
Ø(Ø{{×'Ñ'¬ Ó2Ð2eÐ2ØA~ô
|
mm AÓ&×&Ð&Ø Ð&Ø ll 5Ó)×)Ñ)à ll 5Ð)9¨/Ð#:Ó;×;Ð;Ø ¤3 u£:Ñ-Ø" aÒ'ØØ !OJð {{×'Ñ'¬ Ó2Ð2eÓ2ð 'øà)øà;ús< ACÁCÁCÁ0CÁ1 CÂ CÂ>CÃ CÃCÃCc ó^ K | j « | j j « S w)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 s r7 r® zBytesIOPayload.as_bytes s' è ø ð ×+Ñ+Ô-Ø{{× Ñ Ó!Ð!ùs +-c ó K yw)z
|
Close the BytesIO payload.
|
|
This does nothing since BytesIO is in-memory and does not require explicit closing.
|
Nr5 rZ s r7 r³ zBytesIOPayload.close r¦ r§ rµ rd )r1 r2 r3 r ÚBytesIOr¸ r¹ rl r rO r» r r· r r r¥ r r« r¼ r® r³ rÐ rÑ s @r7 r& r& M sÌ ø
Ø JJÓØ JØJðGbjjð G°ð GÀð GÈõ Gð
|
ðcò ó ðñ;sð ;°cð ;Èó ;ð:Ð"6ð :¸4ó :ð' Ø*ð' Ø<DÀS¹Mð' à ó' ñR" sð "¸cð "ÐQVó "÷ r6 r& c óB e Zd ZU ej ed< ddededefdZy)r' rx rq r r@ c óv | j « | j j « j ||« S rB r r s r7 r z BufferedReaderPayload.decode¦ r! r6 Nrµ )r1 r2 r3 r ÚBufferedIOBaser¸ r· r r5 r6 r7 r' r' ¢ s(
Ø × Ñ Ó ñ;sð ;°cð ;Èô ;r6 r' c óX e Zd Zddej fdedededededed d
|
f fd Z xZ S ) r* r zapplication/jsonrm rq ro Údumpsr> r? r@ Nc ó\ t | ||« j |« g|¢||d|¤ y )Nr )rÀ rO r )rN rm rq ro r. r> r? rÊ s r7 rO zJsonPayload.__init__¬ sC ø ô ÑÙ %L× Ñ Ó )ð
|
ð ñ
|
à%Ø ñ
|
ð
|
ó
|
r6 )
|
r1 r2 r3 Újsonr. r r· r rO rÐ rÑ s @r7 r* r* « s` ø ð Ø .Ø !ZZñ
|
àð
|
ð ð
|
ð ð
|
ð
|
ð
|
ð ð
|
ð ð
|
ð
|
÷
|
ñ
|
r6 r* )Ú AsyncIterableÚ AsyncIteratorc óÄ e Zd ZU dZee ed< eed< dZee e
|
ed< dZ dede de d df fd
|
Z d ed dfd Zd ed ee d dfdZddeded efdZddeded e
|
fdZ xZS )r+ NÚ_iterrx Ú_cached_chunksTrm r> r? r@ c óÎ t |t « s#t dj t |« « « d|vrd|d< t | |g|¢i |¤ |j « | _ y )NzMvalue argument must support collections.abc.AsyncIterable interface, got {!r}ro rh ) r] r1 rÅ ÚformatrG rÀ rO Ú __aiter__r4 rÉ s r7 rO z AsyncIterablePayload.__init__Ó sf ø Ü%¤ Ô/Üðç!6¤$ u£+Ó.óð ð Ñ 'Ø%?F>Ñ "ä ÑÐ0 Ò0¨Ò0à__Ó&
|
r6 r¢ c óD K | j |d« d{ y7 w)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¤ s r7 r¥ zAsyncIterablePayload.writeâ s è ø ð ×$Ñ$ V¨TÓ2×2Ò2úrõ r¨ c ó K | j a|}| j D ]O }||j |« d{ |dkD r+|j |d| « d{ |t |« z }O y y| j y|} t j
|
dk\ r t | j « d{ }n"| j j « d{ }||j |« d{ n/|dkD r*|j |d| « d{ |t |« z }7 é7 É7 w7 V7 =7 # t $ r d| _ d| _ Y yw xY ww)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()
|
|
Nr T)rs é
|
)
|
r5 r¥ rÄ r4 rz r{ ÚanextÚ __anext__ÚStopAsyncIterationrk )rN r¢ r¨ r& rþ s r7 r« z&AsyncIterablePayload.write_with_lengthó s\ è ø ð& × Ñ Ð *Ø ,OØ ×,Ñ,ò Ø"Ð*Ø ,, uÓ-×-Ñ-Ø$ qÒ(Ø ,, uÐ-=¨oÐ'>Ó?×?Ð?Ø#¤s¨5£zÑ1OàØ ð ð ð ::Ð Ø ð )ð "ØÜ×#Ñ# wÒ.Ü"'¨¯
|
©
|
Ó"3× 3Eà"&§*¡*×"6Ñ"6Ó"8× 8EØ"Ð*Ø ,, uÓ-×-Ñ-à$ qÒ(Ø ,, uÐ-=¨oÐ'>Ó?×?Ð?Ø#¤s¨5£zÑ1Oð ð! .øà?øð 4øà 8øà-øð @ùô "ò "à DJØ !DNð "üs 4E ¶D ·!E ÁD"Á&E  ,D, Â,D$Â-"D, ÃD&ÃD, Ã*D(Ã+!D, Ä D*Ä D, Ä E Ä"E Ä$D, Ä&D, Ä(D, Ä*D, Ä,EÅE ÅEÅE rq r c ó | j +dj | j « j ||« S t d« )zFDecode the payload content as a string if cached chunks are available.r6 z=Unable to decode - content not cached. Call as_bytes() first.)r5 r r rÅ r s r7 r zAsyncIterablePayload.decode. s< à × Ñ Ð *Ø88D× /Ñ /Ó0×7Ñ7¸À&ÓIÐ IÜÐWÓXÐXr6 c ó K | j dj | j « S | j yg }| j 2 3 d{ }|j |« 7 6 d| _ || _ dj |« S w)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.
|
Nr6 )r5 r r4 ra )rN rq r Úchunksrþ s r7 r® z AsyncIterablePayload.as_bytes4 s è ø ð × Ñ Ð *Ø88D× /Ñ /Ó0Ð 0ð ::Ð Øð !Ø ::÷ !ð !%Ø MM%Õ ð !ø:ð
|
Ø $Ôð xxÓ Ð ùs* ABÁA"Á A Á
|
A"Á BÁ A"Á" Brµ )r1 r2 r3 r4 r Ú_AsyncIteratorr¸ Ú_AsyncIterabler5 r r¼ rl r rO r r¥ r¹ r« r· r r® rÐ rÑ s @r7 r+ r+ Ë sÀ ø
à&*E8NÑ #Ó*Ø ÓØ,0NHT %[Ñ)Ó0àJð 'nð '°Sð 'ÀCð 'ÈDõ 'ð 3Ð"6ð 3¸4ó 3ð"9"Ø*ð9"Ø<DÀS¹Mð9"à ó9"ñvYsð Y°cð YÈó Yñ sð ¸cð ÐQV÷ r6 r+ c ó0 e Zd Zdedededdf fd Z xZS )ÚStreamReaderPayloadrm r> r? r@ Nc óH t | |j « g|¢i |¤ y rB )rÀ rO Úiter_anyrÉ s r7 rO z StreamReaderPayload.__init__Q s! ø Ü Ñ Ó)Ð;¨DÒ;°FÓ;r6 )r1 r2 r3 r r rO rÐ rÑ s @r7 rE rE P s) ø ð<lð <°3ð <À#ð <È$÷ <ñ <r6 rE )[r÷ Úenumr r0 r| rï rz rÆ Úabcr r Úcollections.abcr Ú itertoolsr Útypingr r r r
|
r r r r r r r r Ú multidictr r r r Úhelpersr r r r r Ústreamsr Útypedefsr r Ú__all__r, r¹ r¸ r- Úsetr. ÚFutureÚ Exceptionr0 r· ÚEnumr9 r r: rK r! rf Ú_PayloadRegistryItemrS r" r# r$ r) r% r( r& r' r* r1 r2 r¼ rB rC r+ rE r rJ rà rÁ ÚStringIOr r) ÚBufferedReaderÚBufferedRandomr r< r5 r6 r7 ú<module>rZ sÐ ðÜ Û Û Û Û Û Û
|
Û ß #Ý $Ý ÷ ÷ ÷ ó õ "å Ý %÷õ õ "ß /ð ð $)Ð eCjÓ (Ø 5:Ó Ù,/«EGNN 4Ñ(Ñ)Ó 1ôK)ô KôCô ð 7cð 7 #ð 7°ð 7¸ó 7ð
|
<A¿<¹<ò:Ø )_ð:Ø$'ð:Ø38ð:à ó:÷ ñ ð 9o Ø [¨#Ð -Ñ.Ð ÷4=ñ 4=ônDcô DôNM,7ô M,ô`
|
Lô
|
ô>8mô 8ô
|
F@Gô F@ôRoBMô oBôdR ]ô R ôj;Mô ;ô
|
,ô
|
ñ( ß3à" 5Ñ)NØ" 5Ñ)Nç<à"NØ"NôB 7ô B ôJ<Ð.ô <ñ
|
#Ó$Ð Ø × Ñ ,¨° ¸:Ð(FÔ GØ × Ñ -¨Ô -Ø × Ñ /¨2¯;©;Ô 7Ø × Ñ -¨¯ © Ô 7Ø × Ñ .¨"¯*©*Ô 5Ø × Ñ Ð/°"×2CÑ2CÀR×EVÑEVÐ1WÔ XØ × Ñ -¨¯©Ô 3Ø × Ñ Ð-¨|Ô <ð × Ñ Ð.° ÀUÇ^Á^Ð Õ Tr6
|
