+
    i                    p   ^ 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# )$    )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                  :    ] 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 )formats   "a/Users/igloo/.openclaw/workspace/scratch/fb_ad_env/lib/python3.14/site-packages/httpx/_content.py__annotate__ByteStream.__annotate__    s      u      c                	    Wn         R # N_streamselfr   s   &&r!   __init__ByteStream.__init__    s    r$   c                   V ^8  d   QhRR/# r   r   zIterator[bytes]r   )r    s   "r!   r"   r#   #   s      / r$   c              #  	*   "   V P                   x  R # 5ir&   r'   r*   s   &r!   __iter__ByteStream.__iter__#   s     lls   c                   V ^8  d   QhRR/# r   r   zAsyncIterator[bytes]r   )r    s   "r!   r"   r#   &   s      !5 r$   c               	,   "   V P                   5x  R # 5ir&   r'   r0   s   &r!   	__aiter__ByteStream.__aiter__&   s     lls   r'   N)__name__
__module____qualname____firstlineno__r+   r1   r6   __static_attributes__r   r$   r!   r   r      s     r$   c                  2    ] tR t^*tRtR R ltR R ltRtR# )IteratorByteStream   c                    V ^8  d   QhRRRR/# )r   r   zIterable[bytes]r   r   r   )r    s   "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inspectisgenerator_is_generatorr)   s   &&r!   r+   IteratorByteStream.__init__-   s"    #( $008r$   c                   V ^8  d   QhRR/# r.   r   )r    s   "r!   r"   rA   2   s      / r$   c              #  	  "   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)rD   rG   r   hasattrr(   rK   
CHUNK_SIZEr*   chunkparts   &  r!   r1   IteratorByteStream.__iter__2   s     ###(:(:(: ""#' 4<<((LL%%doo6E))$//: 
 
 %s   $CACACrG   rD   r(   N)r8   r9   r:   r;   rM   r+   r1   r<   r   r$   r!   r>   r>   *   s    J9
 r$   r>   c                  2    ] tR t^CtRtR R ltR R ltRtR# )AsyncIteratorByteStreamr?   c                    V ^8  d   QhRRRR/# )r   r   zAsyncIterable[bytes]r   r   r   )r    s   "r!   r"   $AsyncIteratorByteStream.__annotate__F   s     8 83 8 8r$   c                	V    Wn         R V n        \        P                  ! V4      V n        R# rC   )r(   rD   rE   
isasyncgenrG   r)   s   &&r!   r+    AsyncIteratorByteStream.__init__F   s"    #( $//7r$   c                   V ^8  d   QhRR/# r4   r   )r    s   "r!   r"   rV   K   s      !5 r$   c               	  "   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)rD   rG   r   rL   r(   r\   rM   rN   s   &  r!   r6   !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%rR   N)r8   r9   r:   r;   rM   r+   r6   r<   r   r$   r!   rT   rT   C   s    J8
 r$   rT   c                  2    ] 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                   V ^8  d   QhRR/# r.   r   )r    s   "r!   r"   UnattachedStream.__annotate__c   s      / r$   c                	    \        4       hr&   r   r0   s   &r!   r1   UnattachedStream.__iter__c   s
    nr$   c                   V ^8  d   QhRR/# r4   r   )r    s   "r!   r"   ra   f   s      !5 r$   c               	   "   \        4       h5i)r$   rc   r0   s   &r!   r6   UnattachedStream.__aiter__f   s     ns   r   N)r8   r9   r:   r;   __doc__r1   r6   r<   r   r$   r!   r_   r_   \   s     r$   r_   c                    V ^8  d   QhRRRR/# )r   contentz4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r   7tuple[dict[str, str], SyncByteStream | AsyncByteStream]r   )r    s   "r!   r"   r"   k   s      I IAI<Ir$   c                   \        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-EncodingchunkedzUnexpected type for 'content', )
isinstancer   strencodelenr   r   dictr   r>   r   rT   	TypeErrortype)rj   bodycontent_lengthheaderscontent_length_or_nones   &    r!   encode_contentr{   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                    V ^8  d   QhRRRR/# )r   datar   r   !tuple[dict[str, str], ByteStream]r   )r    s   "r!   r"   r"      s     % %
%&%r$   c           
        . 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)doseqrm   z!application/x-www-form-urlencodedrn   Content-Type)itemsrp   listtupleextendr   appendr   rr   rq   rs   r   )	r}   
plain_datakeyvalueitemrw   rx   content_typery   s	   &        r!   encode_urlencoded_datar      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               (    V ^8  d   QhRRRRRRRR/# )	r   r}   r   filesr   boundarybytes | Noner   z&tuple[dict[str, str], MultipartStream]r   )r    s   "r!   r"   r"      s,      
*6B+r$   c                B    \        WVR 7      pVP                  4       pWC3# ))r}   r   r   )r   get_headers)r}   r   r   	multipartry   s   &&&  r!   encode_multipart_datar      s'      TJI##%Gr$   c                    V ^8  d   QhRRRR/# )r   textrq   r   r~   r   )r    s   "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# )rm   ztext/plain; charset=utf-8rn   r   rr   rq   rs   r   )r   rw   rx   r   ry   s   &    r!   encode_textr      s@    ;;wDT^N.LNGJt$$$r$   c                    V ^8  d   QhRRRR/# )r   htmlrq   r   r~   r   )r    s   "r!   r"   r"      r   r$   c                v    V P                  R 4      p\        \        V4      4      pRpRVRV/pV\        V4      3# )rm   ztext/html; charset=utf-8rn   r   r   )r   rw   rx   r   ry   s   &    r!   encode_htmlr      s@    ;;wDT^N-LNGJt$$$r$   c                    V ^8  d   QhRRRR/# )r   jsonr   r   r~   r   )r    s   "r!   r"   r"      s     % %c %? %r$   c                    \        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)ensure_ascii
separators	allow_nanrm   zapplication/jsonrn   r   ),:)
json_dumpsrr   rq   rs   r   )r   rw   rx   r   ry   s   &    r!   encode_jsonr      sS    5Z5fWo 	 T^N%LNGJt$$$r$   c               0    V ^8  d   QhRRRRRRRRR	R
RR/# )r   rj   zRequestContent | Noner}   zRequestData | Noner   zRequestFiles | Noner   
Any | Noner   r   r   rk   r   )r    s   "r!   r"   r"      sD        " 
    	 
   = r$   c                B   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.)
stacklevelr$   )
rp   r
   warningswarnDeprecationWarningr{   r   r   r   r   )rj   r}   r   r   r   messages   &&&&& r!   encode_requestr      s     
4 9 9 Jg1a@d##g&&	$TZZRAA	%d++		4  z#r$   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r   rj   zResponseContent | Noner   z
str | Noner   r   r   r   rk   r   )r    s   "r!   r"   r"      s:      #
  	
 =r$   c                    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$   )r{   r   r   r   r   )rj   r   r   r   s   &&&&r!   encode_responser      sW     g&&		4  		4  		4  z#r$   )NNNNN)NNNN),
__future__r   rE   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   r>   rT   r_   r{   r   r   r   r   r   r   r   r   r$   r!   <module>r      s    "   $  # 5 '  A..  2o 2 I:% %%% F r$   