+
     h  c                  sp   ^ RI Ht ^ RIt^ RIt^ RIHt ^ RIHtH	t	H
t
HtHtHt ^ RIHt ^RIHtHt ^RIHt ^RIHtHtHtHtHtHt ^R	IHtHt R
.t ! R R
]]4      t  ! R R]4      t! ! R R]4      t" ! R R]]4      t#R R lt$R R lt%R R lt&R R lt'R R lt(R R lt)R"R R llt*R#R  R! llt+R# )$i    )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                  s:    ] tR t^tR R ltR R ltR R ltRtR# )	r   c                    V ^8  d   QhRRRR/# )   streambytesreturnNone Zformat   "3/usr/lib/python3.14/site-packages/httpx/_content.py__annotate__ByteStream.__annotate__    s      u      c                	s    Wn         R # N_streamselfr      &&r   __init__ZByteStream.__init__    s    r!   c                   V ^8  d   QhRR/# r   r   zIterator[bytes]r   r   r   r   r   r    #   s      / r!   c              #  	s*   "   V P                   x  R # 5ir"   r#   r&      &r   __iter__ZByteStream.__iter__#   s     lls   c               r)   r   r   zAsyncIterator[bytes]r   r   r   r   r   r    &   s      !5 r!   c               	s,   "   V P                   5x  R # 5ir"   r#   r+   r,   r   	__aiter__ZByteStream.__aiter__&   s     lls   r#   N)__name__
__module____qualname____firstlineno__r(   r-   r/   __static_attributes__r   r!   r   r   r      s     r!   c                  s2    ] tR t^*tRtR R ltR R ltRtR# )IteratorByteStream   c               r   )r   r   zIterable[bytes]r   r   r   r   r   r   r   IteratorByteStream.__annotate__-   s     9 9 94 9r!   c                	V    Wn         R V n        \        P                  ! V4      V n        R# FN)r$   _is_stream_consumedinspectZisgenerator_is_generatorr%   r'   r   r(   ZIteratorByteStream.__init__-   s"    #( $008r!   c               r)   r*   r   r   r   r   r   r7   2   s      / r!   c              #  	s  "   V P                   '       d   V P                  '       d   \        4       hR V n         \        V P                  R4      '       d[   V P                  P                  V P                  4      pV'       d,   Vx  V P                  P                  V P                  4      pK3  R# V P                   F  pVx  K	  	  R# 5i)TreadN)r:   r<   r
   hasattrr$   r=   
CHUNK_SIZEr&   ZchunkZpart   &  r   r-   ZIteratorByteStream.__iter__2   s     ###(:(:(: ""#' 4<<((LL%%doo6E))$//: 
 
 %s   $CACACr<   r:   r$   N)r0   r1   r2   r3   r?   r(   r-   r4   r   r!   r   r5   r5   *   s    J9
 r!   r5   c                  s2    ] tR t^CtRtR R ltR R ltRtR# )AsyncIteratorByteStreamr6   c               r   )r   r   zAsyncIterable[bytes]r   r   r   r   r   r   r   $AsyncIteratorByteStream.__annotate__F   s     8 83 8 8r!   c                	r8   r9   )r$   r:   r;   Z
isasyncgenr<   r%   r'   r   r(   Z AsyncIteratorByteStream.__init__F   s"    #( $//7r!   c               r)   r.   r   r   r   r   r   rD   K   s      !5 r!   c               	s  "   V P                   '       d   V P                  '       d   \        4       hR V n         \        V P                  R4      '       dl   V P                  P                  V P                  4      G Rj  xL
 pV'       d5   V5x  V P                  P                  V P                  4      G Rj  xL
 pK<  R# V P                    Rj  xL
  pV5x  K   L_ L' LDR# 5i)TareadN)r:   r<   r
   r>   r$   rE   r?   r@   rA   r   r/   Z!AsyncIteratorByteStream.__aiter__K   s     ###(:(:(: ""#' 4<<)),,,,T__==E"ll00AA 
 #ll  d
 > BlsS   $C%AC%<C=C%	-C%6C7C%C"C C"
C%C% C""C%rB   N)r0   r1   r2   r3   r?   r(   r/   r4   r   r!   r   rC   rC   C   s    J8
 r!   rC   c                  s2    ] tR t^\tRtR R ltR R ltRtR# )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               r)   r*   r   r   r   r   r   UnattachedStream.__annotate__c   s      / r!   c                	s    \        4       hr"   r	   r+   r,   r   r-   ZUnattachedStream.__iter__c   s
    nr!   c               r)   r.   r   r   r   r   r   rG   f   s      !5 r!   c               	s   "   \        4       h5i)r!   rH   r+   r,   r   r/   ZUnattachedStream.__aiter__f   s     ns   r   N)r0   r1   r2   r3   Z__doc__r-   r/   r4   r   r!   r   rF   rF   \   s     r!   rF   c               r   )r   contentz4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r   7tuple[dict[str, str], SyncByteStream | AsyncByteStream]r   r   r   r   r   r   k   s      I IAI<Ir!   c                s   \        V \        \        34      '       dY   \        V \        4      '       d   V P                  R 4      MT p\	        V4      pV'       d   R\        V4      /M/ pV\        V4      3# \        V \        4      '       dE   \        V \        4      '       g/   \        V 4      pVf   RR/pMR\        V4      /pV\        V 4      3# \        V \        4      '       d   RR/pV\        V 4      3# \        R\        V 4      : 24      h)utf-8Content-LengthzTransfer-EncodingZchunkedzUnexpected type for 'content', )
isinstancer   strencodelenr   r   Zdictr   r5   r   rC   Z	TypeErrorZtype)rI   bodycontent_lengthheadersZcontent_length_or_none   &    r   encode_contentrU   k   s     'E3<((*4Wc*B*Bw~~g&T=A#S%89r
4(((	GX	&	&z'4/H/H
 "6g!>!)*I6G'-C)DEG*7333	G]	+	+&	2/888
5d7m5FG
HHr!   c               r   )r   datar   r   !tuple[dict[str, str], ByteStream]r   r   r   r   r   r      s     % %
%&%r!   c           
     s   . pV P                  4        Fj  w  r#\        V\        \        34      '       d.   TP	                  V Uu. uF  qB\        V4      3NK  	  up4       KN  VP                  V\        V4      34       Kl  	  \        VR R7      P                  R4      p\        \        V4      4      pRpRVRV/pV\        V4      3# u upi )T)ZdoseqrK   z!application/x-www-form-urlencodedrL   Content-Type)ZitemsrM   ZlistZtupleZextendr   Zappendr   rO   rN   rP   r   )	rV   Z
plain_dataZkeyZvalueZitemrQ   rR   content_typerS   s	   &        r   encode_urlencoded_datarZ      s     Jjjl
edE]++uUut%;D%ABuUVs$:5$ABC	 #
 Zt,33G<DT^N6LNGJt$$$ Vs   C
c               s(    V ^8  d   QhRRRRRRRR/# )	r   rV   r   filesr   boundarybytes | Noner   z&tuple[dict[str, str], MultipartStream]r   r   r   r   r   r      s,      
*6B+r!   c                sB    \        WVR 7      pVP                  4       pWC3# ))rV   r[   r\   )r   Zget_headers)rV   r[   r\   Z	multipartrS   s   &&&  r   encode_multipart_datar^      s'      TJI##%Gr!   c               r   )r   textrN   r   rW   r   r   r   r   r   r           % %c %? %r!   c                v    V P                  R 4      p\        \        V4      4      pRpRVRV/pV\        V4      3# )rK   ztext/plain; charset=utf-8rL   rX   rO   rN   rP   r   )r_   rQ   rR   rY   rS   rT   r   encode_textrc      s@    ;;wDT^N.LNGJt$$$r!   c               r   )r   htmlrN   r   rW   r   r   r   r   r   r      r`   r!   c                ra   )rK   ztext/html; charset=utf-8rL   rX   rb   )rd   rQ   rR   rY   rS   rT   r   encode_htmlre      s@    ;;wDT^N-LNGJt$$$r!   c               r   )r   jsonr   r   rW   r   r   r   r   r   r      s     % %c %? %r!   c                s    \        V R RR R7      P                  R4      p\        \        V4      4      pRpRVRV/pV\	        V4      3# )F)Zensure_asciiZ
separatorsZ	allow_nanrK   zapplication/jsonrL   rX   )Z,Z:)
json_dumpsrO   rN   rP   r   )rf   rQ   rR   rY   rS   rT   r   encode_jsonrh      sS    5Z5fWo 	 T^N%LNGJt$$$r!   c               s0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   rI   zRequestContent | NonerV   zRequestData | Noner[   zRequestFiles | Nonerf   
Any | Noner\   r]   r   rJ   r   r   r   r   r   r      sD        " 
    	 
   = r!   c                sB   VeA   \        V\        4      '       g+   Rp\        P                  ! V\        ^R7       \        V4      # V e   \        V 4      # V'       d   \        T;'       g    / W$4      # V'       d   \        V4      # Ve   \        V4      # / \        R4      3# )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.)Z
stacklevelr!   )
rM   r   warningsZwarnZDeprecationWarningrU   r^   rZ   rh   r   )rI   rV   r[   rf   r\   Zmessages   &&&&& r   encode_requestrk      s     
4 9 9 Jg1a@d##g&&	$TZZRAA	%d++		4  z#r!   c          
     s,    V ^8  d   QhRRRRRRRRRR	/# )
r   rI   zResponseContent | Noner_   z
str | Nonerd   rf   ri   r   rJ   r   r   r   r   r   r      s:      #
  	
 =r!   c                s    V e   \        V 4      # Ve   \        V4      # Ve   \        V4      # Ve   \        V4      # / \	        R4      3# )zW
Handles encoding the given `content`, returning a two-tuple of
(<headers>, <stream>).
r!   )rU   rc   re   rh   r   )rI   r_   rd   rf   s   &&&&r   encode_responserl      sW     g&&		4  		4  		4  z#r!   )NNNNN)NNNN),Z
__future__r    r;   rj   rf   r   rg   Ztypingr   r   r   r   r   r   Zurllib.parser   Z_exceptionsr	   r
   Z
_multipartr   Z_typesr   r   r   r   r   r   Z_utilsr   r   Z__all__r   r5   rC   rF   rU   rZ   r^   rc   re   rh   rk   rl   r   r!   r   <module>rm      s    "   $  # 5 '  A..  2o 2 I:% %%% F r!   