ó
    §ZÇhá  ã                  ó¸  • S SK Jr  S SKrS SKrS SKJr  S SKJrJ	r	J
r
JrJrJr  S SKJr  SSKJrJr  SSKJr  SS	KJrJrJrJrJrJr  SS
KJrJr  S/r " S S\\5      r  " S S\5      r! " S S\5      r" " S S\\5      r#    SS jr$    SS jr%        SS jr&SS jr'SS jr(S S jr)     S!           S"S jjr*    S#         S$S jjr+g)%é    )Ú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                  ó2   • \ rS rSrSS jrSS jrS	S jrSrg)
r   é   c                ó   • Xl         g ©N©Ú_stream©ÚselfÚstreams     ÚK/home/mande/repo/quber/.venv/lib/python3.13/site-packages/httpx/_content.pyÚ__init__ÚByteStream.__init__    s   € Ø�ó    c              #  ó(   #   • U R                   v •  g 7fr   r   ©r    s    r"   Ú__iter__ÚByteStream.__iter__#   s   é € Ø�l‰lÓùs   ‚c               ó*   #   • U R                   7v •  g 7fr   r   r'   s    r"   Ú	__aiter__ÚByteStream.__aiter__&   s   é € Ø�l‰lÔùs   ‚r   N)r!   ÚbytesÚreturnÚNone©r.   zIterator[bytes]©r.   zAsyncIterator[bytes])Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r#   r(   r+   Ú__static_attributes__© r%   r"   r   r      s   † ôô÷r%   c                  ó,   • \ rS rSrSrSS jrSS jrSrg)	ÚIteratorByteStreamé*   é   c                óT   • Xl         SU l        [        R                  " U5      U l        g ©NF)r   Ú_is_stream_consumedÚinspectÚisgeneratorÚ_is_generatorr   s     r"   r#   ÚIteratorByteStream.__init__-   s"   € ØŒØ#(ˆÔ Ü$×0Ò0°Ó8ˆÕr%   c              #  ó–  #   • U R                   (       a  U R                  (       a
  [        5       eSU l         [        U R                  S5      (       a`  U R                  R                  U R                  5      nU(       a3  Uv •  U R                  R                  U R                  5      nU(       a  M2  g g U R                   H  nUv •  M	     g 7f)NTÚread)r>   rA   r   Úhasattrr   rD   Ú
CHUNK_SIZE©r    ÚchunkÚparts      r"   r(   ÚIteratorByteStream.__iter__2   sŒ   é € Ø×#×#¨×(:×(:Ü Ó"Ð"à#'ˆÔ Ü�4—<‘< ×(Ñ(à—L‘L×%Ñ% d§o¡oÓ6ˆEÞØ’ØŸ™×)Ñ)¨$¯/©/Ó:�÷ ’%ð
 Ÿœ�Ø”
ò %ùs   ‚B+C	Â/C	©rA   r>   r   N)r!   zIterable[bytes]r.   r/   r0   )r2   r3   r4   r5   rF   r#   r(   r6   r7   r%   r"   r9   r9   *   s   † Ø€Jô9÷
r%   r9   c                  ó,   • \ rS rSrSrSS jrSS jrSrg)	ÚAsyncIteratorByteStreaméC   r;   c                óT   • Xl         SU l        [        R                  " U5      U l        g r=   )r   r>   r?   Ú
isasyncgenrA   r   s     r"   r#   Ú AsyncIteratorByteStream.__init__F   s"   € ØŒØ#(ˆÔ Ü$×/Ò/°Ó7ˆÕr%   c               óÐ  #   • U R                   (       a  U R                  (       a
  [        5       eSU l         [        U R                  S5      (       aq  U R                  R                  U R                  5      I S h  v•N nU(       a<  U7v •  U R                  R                  U R                  5      I S h  v•N nU(       a  M;  g g U R                    S h  v•N nU7v •  M   Nd N- N
 g 7f)NTÚaread)r>   rA   r   rE   r   rS   rF   rG   s      r"   r+   Ú!AsyncIteratorByteStream.__aiter__K   s¤   é € Ø×#×#¨×(:×(:Ü Ó"Ð"à#'ˆÔ Ü�4—<‘< ×)Ñ)àŸ,™,×,Ñ,¨T¯_©_Ó=×=ˆEÞØ“Ø"Ÿl™l×0Ñ0°·±ÓA×A�÷ ’%ð
 #Ÿlšl÷ �dØ•
ñ >ñ Bñ™lùsN   ‚A7C&Á9CÁ:8C&Â2C Â3C&Ã C&ÃC$ÃC"ÃC$Ã	C&Ã C&Ã"C$Ã$C&rK   N)r!   zAsyncIterable[bytes]r.   r/   r1   )r2   r3   r4   r5   rF   r#   r+   r6   r7   r%   r"   rM   rM   C   s   † Ø€Jô8÷
r%   rM   c                  ó,   • \ rS rSrSrSS jrSS jrSrg)	ÚUnattachedStreamé\   z¯
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                ó   • [        5       er   ©r   r'   s    r"   r(   ÚUnattachedStream.__iter__c   s
   € Ü‹nÐr%   c               ó   #   • [        5       e7fr   rY   r'   s    r"   r+   ÚUnattachedStream.__aiter__f   s   é € Ü‹nÐùs   ‚r7   Nr0   r1   )r2   r3   r4   r5   Ú__doc__r(   r+   r6   r7   r%   r"   rV   rV   \   s   † ñô÷r%   rV   c                ó  • [        U [        [        45      (       aV  [        U [        5      (       a  U R                  S5      OU n[	        U5      nU(       a  S[        U5      0O0 nU[        U5      4$ [        U [        5      (       aB  [        U [        5      (       d-  [        U 5      nUc  SS0nOS[        U5      0nU[        U 5      4$ [        U [        5      (       a  SS0nU[        U 5      4$ [        S[        U 5      < 35      e)Núutf-8úContent-LengthzTransfer-EncodingÚchunkedzUnexpected type for 'content', )Ú
isinstancer-   ÚstrÚencodeÚlenr   r   Údictr   r9   r   rM   Ú	TypeErrorÚtype)ÚcontentÚbodyÚcontent_lengthÚheadersÚcontent_length_or_nones        r"   Úencode_contentrn   k   sõ   € ô �'œE¤3˜<×(Ñ(Ü*4°W¼c×*BÑ*Bˆw�~‰~˜gÔ&ÈˆÜ˜T›ˆÞ=AÐ#¤S¨Ó%8Ñ9ÀrˆØœ
 4Ó(Ð(Ð(ä	�GœX×	&Ñ	&¬z¸'Ä4×/HÑ/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           
     óŒ  • / nU R                  5        Hj  u  p#[        U[        [        45      (       a.  UR	                  U Vs/ s H  oB[        U5      4PM     sn5        MN  UR                  U[        U5      45        Ml     [        USS9R                  S5      n[        [        U5      5      nSnXgS.nU[        U5      4$ s  snf )NT)Údoseqr_   z!application/x-www-form-urlencoded©r`   zContent-Type)Úitemsrb   ÚlistÚtupleÚextendr   Úappendr   rd   rc   re   r   )	ÚdataÚ
plain_dataÚkeyÚvalueÚitemrj   rk   Úcontent_typerl   s	            r"   Úencode_urlencoded_datar}   ˆ   s´   € ð €JØ—j‘j–l‰
ˆÜ�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Ó$Ð$Ð$ùò Vs   ÁC
c                ó<   • [        XUS9nUR                  5       nXC4$ )N)rw   ÚfilesÚboundary)r   Úget_headers)rw   r   r€   Ú	multipartrl   s        r"   Úencode_multipart_datarƒ   ˜   s'   € ô   TÀÑJ€IØ×#Ñ#Ó%€GØÐÐr%   c                ór   • U R                  S5      n[        [        U5      5      nSnX#S.nU[        U5      4$ )Nr_   ztext/plain; charset=utf-8rq   ©rd   rc   re   r   )Útextrj   rk   r|   rl   s        r"   Úencode_textr‡       s:   € Ø�;‰;�wÓ€DÜœ˜T›“^€NØ.€LØ!/ÑN€GØ”J˜tÓ$Ð$Ð$r%   c                ór   • U R                  S5      n[        [        U5      5      nSnX#S.nU[        U5      4$ )Nr_   ztext/html; charset=utf-8rq   r…   )Úhtmlrj   rk   r|   rl   s        r"   Úencode_htmlrŠ   ¨   s:   € Ø�;‰;�wÓ€DÜœ˜T›“^€NØ-€LØ!/ÑN€GØ”J˜tÓ$Ð$Ð$r%   c                ó†   • [        U SSSS9R                  S5      n[        [        U5      5      nSnX#S.nU[	        U5      4$ )NF)Ú,Ú:)Úensure_asciiÚ
separatorsÚ	allow_nanr_   zapplication/jsonrq   )Ú
json_dumpsrd   rc   re   r   )Újsonrj   rk   r|   rl   s        r"   Úencode_jsonr“   °   sM   € ÜØ˜5¨ZÀ5ñç�fˆWƒoð 	ô œ˜T›“^€NØ%€LØ!/ÑN€GØ”J˜tÓ$Ð$Ð$r%   c                ó.  • Ub<  [        U[        5      (       d'  Sn[        R                  " U[        SS9  [        U5      $ U b  [        U 5      $ U(       a  [        U=(       d    0 X$5      $ U(       a  [        U5      $ Ub  [        U5      $ 0 [        S5      4$ )zt
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%   )
rb   r
   ÚwarningsÚwarnÚDeprecationWarningrn   rƒ   r}   r“   r   )ri   rw   r   r’   r€   Úmessages         r"   Úencode_requestr›   º   s�   € ð Ñ¤
¨4´× 9Ñ 9ð JˆÜ�Š�gÔ1¸aÒ@Ü˜dÓ#Ð#àÑÜ˜gÓ&Ð&Þ	Ü$ T§Z¨R°ÓAÐAÞ	Ü% dÓ+Ð+Ø	Ñ	Ü˜4Ó Ð àŒz˜#‹ÐÐr%   c                óŒ   • U b  [        U 5      $ Ub  [        U5      $ Ub  [        U5      $ Ub  [        U5      $ 0 [	        S5      4$ )zW
Handles encoding the given `content`, returning a two-tuple of
(<headers>, <stream>).
r%   )rn   r‡   rŠ   r“   r   )ri   r†   r‰   r’   s       r"   Úencode_responser�   Ý   sW   € ð ÑÜ˜gÓ&Ð&Ø	Ñ	Ü˜4Ó Ð Ø	Ñ	Ü˜4Ó Ð Ø	Ñ	Ü˜4Ó Ð àŒz˜#‹ÐÐr%   )ri   z4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r.   ú7tuple[dict[str, str], SyncByteStream | AsyncByteStream])rw   r   r.   ú!tuple[dict[str, str], ByteStream])rw   r   r   r   r€   úbytes | Noner.   z&tuple[dict[str, str], MultipartStream])r†   rc   r.   rŸ   )r‰   rc   r.   rŸ   )r’   r   r.   rŸ   )NNNNN)ri   zRequestContent | Nonerw   zRequestData | Noner   zRequestFiles | Noner’   ú
Any | Noner€   r    r.   rž   )NNNN)
ri   zResponseContent | Noner†   ú
str | Noner‰   r¢   r’   r¡   r.   rž   ),Ú
__future__r   r?   r—   r’   r   r‘   Útypingr   r   r   r   r	   r
   Úurllib.parser   Ú_exceptionsr   r   Ú
_multipartr   Ú_typesr   r   r   r   r   r   Ú_utilsr   r   Ú__all__r   r9   rM   rV   rn   r}   rƒ   r‡   rŠ   r“   r›   r�   r7   r%   r"   Ú<module>r«      sb  ðÝ "ã Û Ý $÷÷ õ #ç 5Ý '÷÷ ÷ Aàˆ.€ô� .ô ô˜ô ô2˜oô ô2�¨ô ðIØAðIà<ôIð:%Ø
ð%à&ô%ð Ø
ðØ*ðØ6Bðà+ôô%ô%ô%ð &*Ø#Ø!%ØØ!ð Ø"ð à
ð ð ð ð ð	 ð
 ð ð =õ ðH '+ØØØð	Ø#ðà
ðð ðð ð	ð
 =ör%   