+
    TŎi0                     :   R t ^ RIt^ RIt^ RIHtHtHtHtHtH	t	H
t
HtHt ^ RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^RIHt RtRtR]P6                  u;8*  ;'       d    R8  Mu t]P6                  R8  t];'       g    ]t ! R R
]
4      t]! ^^ 4      t ]! ^^4      t!]]]".]R,          3,          ,          t#]]R.]R,          3,          ,          t$ ! R R	]4      t%R R lt&R R lt']'t( ^ RI)H*t* ]*PP                  t+]'       g   ]+t(R# R#   ], d     R# i ; i)z"Http related parsers and protocol.N)	TYPE_CHECKINGAny	AwaitableCallableIterableList
NamedTupleOptionalUnion)CIMultiDict)AbstractStreamWriterBaseProtocol)ClientConnectionResetError)ZLibCompressor)NO_EXTENSIONSStreamWriterHttpVersioni   c                   ,   a  ] tR t^'t o V 3R ltRtV tR# )r   c                2   < V ^8  d   Qh/ S[ ;R&   S[ ;R&   # )   majorminor)int)format__classdict__s   "b/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/http_writer.py__annotate__HttpVersion.__annotate__'   s     J J      N)__name__
__module____qualname____firstlineno____annotate_func____static_attributes____classdictcell__r   s   @r   r   r   '   s      r   CIMultiDict[str]c                   v  a  ] tR t^4t o RtRtRtRtR'V 3R lR llt]	V 3R lR l4       t
]	V 3R lR l4       tV 3R	 lR
 ltR(V 3R lR lltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltRRRR/V 3R lR lltV 3R lR ltV 3R lR ltV 3R lR  ltR)V 3R! lR" lltV 3R# lR$ ltV 3R% ltR&tV tR# )*r   NFc          
      J   < V ^8  d   QhRS[ RS[P                  RS[RS[RR/# )r   protocolloopon_chunk_senton_headers_sentreturnN)r   asyncioAbstractEventLoop_T_OnChunkSent_T_OnHeadersSent)r   r   s   "r   r   StreamWriter.__annotate__;   sC     , ,, '', &	,
 *, 
,r   c                R    Wn         W n        W0n        W@n        R V n        RV n        R # )NF)	_protocolr-   _on_chunk_sent_on_headers_sent_headers_buf_headers_written)selfr,   r-   r.   r/   s   &&&&&r   __init__StreamWriter.__init__;   s*     "	.;2A-1&+r   c                D   < V ^8  d   QhRS[ S[P                  ,          /# r   r0   )r	   r1   	Transport)r   r   s   "r   r   r5   J   s     ( (8G$5$56 (r   c                .    V P                   P                  # N)r7   	transportr<   s   &r   rD   StreamWriter.transportI   s    ~~'''r   c                    < V ^8  d   QhRS[ /# r@   r   )r   r   s   "r   r   r5   N   s      , r   c                    V P                   # rC   )r7   rE   s   &r   r,   StreamWriter.protocolM   s    ~~r   c                   < V ^8  d   QhRR/# r   r0   Nr    )r   r   s   "r   r   r5   Q   s       r   c                    R V n         R# )TN)chunkedrE   s   &r   enable_chunkingStreamWriter.enable_chunkingQ   s	    r   c                :   < V ^8  d   QhRS[ RS[S[,          RR/# )r   encodingstrategyr0   N)strr	   r   )r   r   s   "r   r   r5   T   s.     N NN3;C=N	Nr   c                (    \        WR 7      V n        R# ))rQ   rR   N)r   	_compress)r<   rQ   rR   s   &&&r   enable_compressionStreamWriter.enable_compressionT   s     (Mr   c                >   < V ^8  d   QhRS[ S[S[S[3,          RR/# r   chunkr0   N)r
   bytes	bytearray
memoryview)r   r   s   "r   r   r5   Y   s'      E%J">? D r   c                   \        V4      pV ;P                  V,          un        V ;P                  V,          un        V P                  P                  pVe   VP                  4       '       d   \        R4      hVP                  V4       R # )N!Cannot write to closing transport)lenbuffer_sizeoutput_sizer7   rD   
is_closingr   write)r<   rZ   sizerD   s   &&  r   _writeStreamWriter._writeY   sh    5zD D NN,,		 4 4 6 6,-PQQr   c                4   < V ^8  d   QhRS[ S[,          RR/# )r   chunksr0   N)r   r[   )r   r   s   "r   r   r5   b   s     ) )(5/ )d )r   c                   ^ pV F  pV\        V4      ,          pK  	  V ;P                  V,          un        V ;P                  V,          un        V P                  P                  pVe   VP                  4       '       d   \        R4      h\        '       g   V\        8  d#   VP                  RP                  V4      4       R# VP                  V4       R# )    Nr_   r   )r`   ra   rb   r7   rD   rc   r   SKIP_WRITELINESMIN_PAYLOAD_FOR_WRITELINESrd   join
writelines)r<   ri   re   rZ   rD   s   &&   r   _writelinesStreamWriter._writelinesb   s    ECJD D D NN,,		 4 4 6 6,-PQQ?d%??OOCHHV,-  (r   c                >   < V ^8  d   QhRS[ S[S[RR3,          RR/# )r   rZ   memoryview[int]memoryview[bytes]r0   N)r
   r[   r\   )r   r   s   "r   r   r5   p   s-     : :5)->@SST:	:r   c                h    \        V4      R R2P                  R4      pV P                  W!R34       R# )z+Write a chunk with proper chunked encoding.x
ascii   
N)r`   encoderp   )r<   rZ   chunk_len_pres   && r   _write_chunked_payload#StreamWriter._write_chunked_payloadp   s4     u:a.-44W=-89r   c                D   < V ^8  d   QhRS[ S[S[RR3,          RS[RR/# )r   rZ   rs   rt   is_eofr0   N)r
   r[   r\   bool)r   r   s   "r   r   r5   w   s9     "% "%UI'8:MMN"% "% 
	"%r   c                   RV n         V P                  pRV n        \        '       d   Vf   Q hV P                  '       g0   V'       d   V P	                  W134       R# V P                  V4       R# V'       dS   \        V4      R R2P                  R4      pV'       d   V P	                  W4VR34       R# V P	                  W4VR34       R# V'       d   V P	                  VR34       R# V P                  V4       R# )	zASend buffered headers with payload, coalescing into single write.TNrv   rw   rx      
0

ry      0

)r;   r:   r   rM   rp   rf   r`   rz   )r<   rZ   r   headers_bufr{   s   &&&  r   _send_headers_with_payload'StreamWriter._send_headers_with_payloadw   s     !%'' = ***|||  +!56  K( "5z!nD188AM  +eEU!VW  +eW!MNk<89KK$r   drainTLIMITi   c                J   < V ^8  d   QhRS[ S[S[S[3,          RS[RS[RR/# )r   rZ   r   r   r0   N)r
   r[   r\   r]   r   r   )r   r   s   "r   r   r5      s?     5# 5#UIz125# 	5#
 5# 
5#r   c                 "   V P                   e   V P                  V4      G Rj  xL
  \        V\        4      '       d,   VP                  \	        V4      8w  d   VP                  R4      pV P                  e.   V P                  P                  V4      G Rj  xL
 pV'       g   R# V P                  eV   \	        V4      pV P                  V8  d   V P                  V,
          V n        M VRV P                   p^ V n        V'       g   R# V P                  '       d_   V P                  '       gM   V P                  VR4       V'       d1   V P                  V8  d    ^ V n        V P                  4       G Rj  xL
  R# V'       dt   V P                  '       d   V P                  V4       MV P!                  V4       V'       d5   V P                  V8  d"   ^ V n        V P                  4       G Rj  xL
  R# R# R# R#  EL ELb L L5i)z
Writes chunk of data to a stream.

write_eof() indicates end of stream.
writer can't be used after write_eof() method being called.
write() return drain future.
NcF)r8   
isinstancer]   nbytesr`   castrU   compresslengthr:   r;   r   ra   r   rM   r|   rf   )r<   rZ   r   r   	chunk_lens   &&$$ r   rd   StreamWriter.write   s     *%%e,,,eZ((||s5z)

3>>%..11%88E;;"E
I{{i'"kkI5m, T%:%:%:++E59))E1#$ jjl""|||++E2E"))E1#$ jjl"" 2u = - 9& # #sw   #H G6A1H G9H $A"H H H -H +H 2G<3H H *H >+H )G>*H 9H <H >H c                (   < V ^8  d   QhRS[ RRRR/# )r   status_lineheadersr)   r0   NrS   )r   r   s   "r   r   r5      s%     	  	 	 );	 		 r   c                   "   V P                   e   V P                  V4      G Rj  xL
  \        W4      pRV n        W0n        R#  L5i)zWrite headers to the stream.NF)r9   _serialize_headersr;   r:   )r<   r   r   bufs   &&& r   write_headersStreamWriter.write_headers   sD        ,''000 6 %	 1s   #AAAc                   < V ^8  d   QhRR/# rK   r    )r   r   s   "r   r   r5      s     ! !d !r   c                    V P                   '       d   V P                  '       d   R# RV n        V P                   pRV n         \        '       d   Vf   Q hV P                  V4       R# )z3Force sending buffered headers if not already sent.NT)r:   r;   r   rf   r<   r   s   & r   send_headersStreamWriter.send_headers   sT       D$9$9$9 $'' =***K r   c                   < V ^8  d   QhRR/# rK   r    )r   r   s   "r   r   r5      s       r   c                   V P                   '       d   R# V P                  '       dw   V P                  '       ge   RV n        V P                  pRV n        \        '       d   Vf   Q hV P                  '       d   V P                  VR34       MGV P                  V4       M5V P                  '       d$   V P                  '       d   V P                  R4       RV n         R# )z&Indicate that the message is complete.NTr   )_eofr:   r;   r   rM   rp   rf   r   s   & r   set_eofStreamWriter.set_eof   s    999 T%:%:%:$(D!++K $D}"... |||  +|!<=K(\\\d333KK%	r   c                $   < V ^8  d   QhRS[ RR/# rY   )r[   )r   r   s   "r   r   r5     s     L LU LT Lr   c                  "   V P                   '       d   R # V'       d(   V P                  e   V P                  V4      G R j  xL
  V P                  '       Ed   . p^ pV'       dH   V P                  P                  V4      G R j  xL
 ;p'       d   \	        V4      pVP                  V4       V P                  P                  4       pV\	        V4      ,          pVP                  V4       V'       g   Q hV P                  '       d   V P                  '       g   RV n        V P                  pR V n        V P                  '       d.   VR R2P                  R4      pV P                  Wg.VORN54       MV P                  V.VO54       V P                  4       G R j  xL
  RV n         R # V P                  '       d.   VR R2P                  R4      pV P                  V.VORN54       M:\	        V4      ^8  d   V P                  V4       MV P                  V^ ,          4       V P                  4       G R j  xL
  RV n         R # V P                  '       dF   V P                  '       g4   V P                  VR4       V P                  4       G R j  xL
  RV n         R # V P                  '       dl   V'       d2   V P                  \	        V4      R R2P                  R4      VR34       MV P                  R4       V P                  4       G R j  xL
  RV n         R # V'       d*   V P                  V4       V P                  4       G R j  xL
  RV n         R #  EL EL EL EL% L LU L5i)NTrv   rw   rx   r   r   )r   r8   rU   r   r`   appendflushr:   r;   rM   rz   rp   r   rf   r   )r<   rZ   ri   
chunks_lencompressed_chunkflush_chunkr   r{   s   &&      r   	write_eofStreamWriter.write_eof  s    999T((4%%e,,, >>>"$FJDNN4K4KE4R.RR*R !12
./....0K#k**JMM+&:    )>)>)>(,%"//$(!<<<'1!nD$9$@$@$IM$$$OfO>NO
 $$k%;F%;<jjl"" 	 |||#-a. 5 < <W E  -!K&!K:J!KLVq  (F1I&**,DI T%:%:%:++E48**,DI <<<  E
1~T*11':ECST L)**,DIKK**,	O - /S0 #    s   M "M MM M %M MM A4M M +M AM MM 8A:M 2M3M M $%M 	M
M )M 1AM MM $M  MM M M M M M M c                   < V ^8  d   QhRR/# rK   r    )r   r   s   "r   r   r5   U  s     
+ 
+T 
+r   c                   "   V P                   pVP                  e/   VP                  '       d   VP                  4       G Rj  xL
  R# R# R#  L
5i)z_Flush the write buffer.

The intended use is to write

  await w.write(data)
  await w.drain()
N)r7   rD   _paused_drain_helper)r<   r,   s   & r   r   StreamWriter.drainU  sD      >>)h.>.>.>((*** /?)*s   ,AAAAc                j   < V ^8  d   Qh/ S[ S[,          ;R&   S[;R&   S[;R&   S[ S[,          ;R&   # )r   r   rM   r   rU   )r	   r   r   r   )r   r   s   "r   r   r5   4   s@     SM     	 
 '. r   )rU   r   r:   r;   r8   r9   r7   ra   rM   r   r-   )NN)deflateN)r   )r!   r"   r#   r$   r   rM   r   rU   r=   propertyrD   r,   rN   rV   rf   rp   r|   r   rd   r   r   r   r   r   r%   r&   r'   r(   s   @r   r   r   4   s      FGD*.I, , ( (   N N
 ) ): :"% "%H5# 	5#
 5# 5#n	  	 ! ! 6L L\
+ 
+C	  r   c                0    V ^8  d   QhR\         R\         /# )r   stringr0   r   )r   s   "r   r   r   b  s        r   c                 8    R V 9   g   RV 9   d   \        R4      hV # )
zRNewline or carriage return detected in headers. Potential header injection attack.)
ValueError)r   s   &r   _safe_headerr   b  s(    v~1
 	
 Mr   c                4    V ^8  d   QhR\         RRR\        /# )r   r   r   r)   r0   )rS   r[   )r   s   "r   r   r   k  s"        s  5G  E  r   c                     R  VP                  4        4       pV R,           RP                  V4      ,           R,           pVP                  R4      # )c              3   j   "   T F)  w  r\        V4      R ,           \        V4      ,           x  K+  	  R# 5i)z: N)r   ).0kvs   &  r   	<genexpr>(_py_serialize_headers.<locals>.<genexpr>l  s'     X<?T)LO;;s   13rw   z

zutf-8)itemsrn   rz   )r   r   headers_genlines   &&  r   _py_serialize_headersr   k  s>    XXK&++k"::ZGD;;wr   )r   r   HttpVersion10HttpVersion11)      rk   )r   r   r   )r      	   )-__doc__r1   systypingr   r   r   r   r   r   r   r	   r
   	multidictr   abcr   base_protocolr   client_exceptionsr   compression_utilsr   helpersr   __all__rm   version_infoIS_PY313_BEFORE_313_2IS_PY_BEFORE_312_9rl   r   r   r   r[   r3   r4   r   r   r   r   aiohttp._http_writer_http_writer_c_serialize_headersImportErrorr    r   r   <module>r      s+   (  

 
 
 " % ' 9 - "
K " "c&6&6CCC %%
2 '==+=* 
 Aq!Aq! (E7IdO#;<=H&8%99T?%JKL k+' k+\	  + 	/'::1  		s   /D 	D DD