+
    P(io)              
          ^ RI t ^ RIt^ RIt^ RIt^ RIHtHt ^ RIH	t	 ^ RI
Ht ^ RIHtHtHtHt ^RIHtHt ]! R^R^R	^R
^/4      tRR R llt ! R R]P
                  P,                  4      t ! R R4      t ! R R]P
                  P,                  4      t ! R R]4      t ! R R]4      t ! R R]4      tRR R lltRtR# )    N)ABCabstractmethod)Path)MappingProxyType)Any	GeneratorTupleUnion)AIOFile
FileIOTypeutf-8zutf-16zUTF-8zUTF-16c                v    V ^8  d   QhR\         R\        R\        R\        R\        \        \        3,          /# )   afp
chunk_sizeoffsetencodingreturn)r   intstrr	   )formats   "S/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/aiofile/utils.py__annotate__r      s<      	!+.:=
38_    c                   "   V^ 8  d8   V P                  RV4      G Rj  xL
 p\        V4      VP                  VR7      3# Rp\        \        P                  V^4      4       F6  pV P                  W,           V4      G Rj  xL
 p VP                  VR7      p M	  Vh\        V4      pW3#  L L-  \         d   pTp Rp?Ka  Rp?ii ; i5i)r   Nr   )
read_byteslendecoderangeENCODING_MAPgetUnicodeDecodeError)	r   r   r   r   chunk_bytes
last_errorretrychunkes	   &&&&     r   unicode_readerr*      s      A~NN2v66;!3!3X!3!FFFJ|''!45NN:+=vFF	&&&9E	 6 [!J! 7
 G " 	J	sL   CB,A C B.CB0C.C0C;C=CCCc                   x   a  ] tR t^-t o RtRt^ ]3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	t
V tR
# )Readerc                ,   < V ^8  d   QhRS[ RS[RS[/# )r   aio_filer   r   r   r   )r   __classdict__s   "r   r   Reader.__annotate__2   s%     
+ 
+
+),
+
+r   c                    \         P                  ! 4       V n        \        V4      V n        \        V4      V n        Wn        V P                  P                  V n        R # N)asyncioLock_Reader__lockr   _Reader__offset_chunk_sizefiler   )selfr.   r   r   s   &&&&r   __init__Reader.__init__2   s>    
 llnFz?			**r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r   r   r
   r   bytes)r   r0   s   "r   r   r1   >   s      %U
"3 r   c           	     8  "   V P                   ;_uu_4       GR j  xL
  V P                  P                  P                  '       dE   V P                  P	                  V P
                  V P                  4      G R j  xL
 p\        V4      pMA\        V P                  V P
                  V P                  V P                  R7      G R j  xL
 w  r!R R R 4      GR j  xL
  V ;P                  X,          un        X#  L L~ L5 L%  + GR j  xL 
 '       g   i     L<; i5iNr   )
r6   r9   modebinaryr   r8   r7   r   r*   r   )r:   r(   r   s   &  r   
read_chunkReader.read_chunk>   s     ;;;;yy~~$$$"ii22$$dmm  !Z
*8IIt//!]]+ %!
 ; 	# 
% ;;;sp   DC6DAC>9C8:A
C>C:C>DC< D8C>:C><D>D	D
D	D	Dc                6   < V ^8  d   QhRS[ S[S[3,          /# r>   r?   )r   r0   s   "r   r   r1   M   s      sEz!2 r   c                h   "   V P                  4       G R j  xL
 pV'       g   \        V4      hV#  L5ir3   )rE   StopAsyncIteration)r:   r(   s   & r   	__anext__Reader.__anext__M   s,     oo''$U++ (s   2022c                   < V ^8  d   QhRR/# )r   r   r,    )r   r0   s   "r   r   r1   U   s      8 r   c                    V # r3   rM   r:   s   &r   	__aiter__Reader.__aiter__U       r   )__lock__offsetr8   r   r9   N)r8   rT   r9   rS   r   i   )__name__
__module____qualname____firstlineno__	__slots__
CHUNK_SIZEr;   rE   rJ   rP   __static_attributes____classdictcell__r0   s   @r   r,   r,   -   s?     GIJ 01$
+ 
+   r   r,   c                   L   a  ] tR t^Yt o RtRV 3R lR lltV 3R lR ltRtV tR# )	Writerc                &   < V ^8  d   QhRS[ RS[/# )r   r.   r   r/   )r   r0   s   "r   r   Writer.__annotate__\   s     % % %# %r   c                f    \        V4      V n        Wn        \        P                  ! 4       V n        R # r3   )r   _Writer__offset_Writer__aio_filer4   r5   _Writer__lock)r:   r.   r   s   &&&r   r;   Writer.__init__\   s    F"llnr   c                :   < V ^8  d   QhRS[ S[S[3,          RR/# )r   datar   Nr?   )r   r0   s   "r   r   ra   a   s$     ' '5e#4 ' 'r   c                  "   V P                   ;_uu_4       GR j  xL
  \        V\        4      '       d   V P                  P	                  V4      pV P                  P                  WP                  4      G R j  xL
  V ;P                  \        V4      ,          un        R R R 4      GR j  xL
  R #  L L: L
  + GR j  xL 
 '       g   i     R # ; i5ir3   )re   
isinstancer   rd   encode_byteswrite_bytesrc   r   r:   rh   s   &&r   __call__Writer.__call__a   sy     ;;;;$$$33D9//--dMMBBBMMSY&M ;; C	 ;;;s]   CB2CAB89B4:&B8 C+B6,C4B86C8C	>C?
C	
C		C)
__aio_filerS   rT   N)__chunk_sizerT   rp   rS   )r   )	rU   rV   rW   rX   rY   r;   rn   r[   r\   r]   s   @r   r_   r_   Y   s     BI% %
' 'r   r_   c                   v   a  ] tR t^jt o Rt^ ]R3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t	V t
R# )
LineReader`  
c                2   < V ^8  d   QhRS[ RS[RS[RS[/# )r   r.   r   r   line_sep)r   r   r   )r   r0   s   "r   r   LineReader.__annotate__m   s-     
 

),

03
r   c                6   \        WVR 7      V n        VP                  P                  '       d   \        P
                  ! 4       M\        P                  ! 4       V n        VP                  P                  '       d   VP                  V4      V n	        R# TV n	        R# )r   r   N)
r,   _LineReader__readerrC   rD   ioBytesIOStringIO_bufferrk   linesep)r:   r.   r   r   rw   s   &&&&&r   r;   LineReader.__init__m   sp     xvN %MM000BJJLbkkm 	 }}### !!(+ 	  	r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r>   r?   )r   r0   s   "r   r   rx   }   s     ! !c5j 1 !r   c                F  "    V P                   P                  4       pV'       d$   VP                  V P                  4      '       d   V# WP                   P	                  4       ,           pV P                   P                  ^ 4       V P                   P                  ^ 4       V P                  P                  4       G Rj  xL
 pV'       g   V# V P                   P                  V4       V P                   P                  V4       V P                   P                  ^ 4       EK   Lb5i)TN)
r   readlineendswithr   readtruncateseekr{   rE   write)r:   linebuffer_remainderr(   s   &   r   r   LineReader.readline}   s     <<((*Ddll33#ll&7&7&99LL!!!$LLa  --2244E''LL/0LLu%LLa  5s$   #D! D!A5D!<D=D!	AD!c                6   < V ^8  d   QhRS[ S[S[3,          /# r>   )r
   r@   r   )r   r0   s   "r   r   rx      s      ucz!2 r   c                   "   V P                  4       G R j  xL
 pV'       g&   V P                  P                  4        \        V4      hV#  L35ir3   )r   r   closerI   )r:   r   s   & r   rJ   LineReader.__anext__   s;     ]]_$LL $T** %s   AA
A(Ac                   < V ^8  d   QhRR/# )r   r   rs   rM   )r   r0   s   "r   r   rx      s      < r   c                    V # r3   rM   rO   s   &r   rP   LineReader.__aiter__   rR   r   )__readerr   r   N)rU   rV   rW   rX   rZ   r;   r   rJ   rP   r[   r\   r]   s   @r   rs   rs   j   s<     J 01$d
 
 ! !(  r   rs   c                   Z  a  ] tR t^t o RtR^ /V 3R lR llt]RV 3R lR ll4       t]V 3R lR l4       t]R V 3R	 lR
 ll4       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R ltV 3R lR ltV 3R lR ltV 3R lR lt]P&                  3V 3R lR lltRtV tR# )"FileIOWrapperBasert   r   c                &   < V ^8  d   QhRS[ RS[/# )r   r   r   r/   )r   r0   s   "r   r   FileIOWrapperBase.__annotate__   s     	! 	!G 	! 	!r   c               4   W n         \        P                  ! 4       V n        Wn        V P                  P
                  P                  '       d3    \        P                  ! VP                  4      P                  V n         R# R#   \         d    ^ T n          R# i ; i)r   N)_offsetr4   r5   _lockr9   rC   	appendingosstatnamest_sizeFileNotFoundError)r:   r   r   s   &&$r   r;   FileIOWrapperBase.__init__   si    \\^
	99>>###!!wwsxx088 $ % ! !s   /B BBc                &   < V ^8  d   QhRS[ RS[/# r   lengthr   )r   r   )r   r0   s   "r   r   r      s     " " "c "r   c                   "   \         h5ir3   NotImplementedErrorr:   r   s   &&r   r   FileIOWrapperBase.read        !!   	c                &   < V ^8  d   QhRS[ RS[/# r   rh   r   )r   r   )r   r0   s   "r   r   r      s     " " " "r   c                   "   \         h5ir3   r   rm   s   &&r   r   FileIOWrapperBase.write   r   r   c                B   < V ^8  d   QhRS[ RS[RS[S[S[3,          /# r   sizenewliner   )r   r   r
   r   r@   )r   r0   s   "r   r   r      s.     " ""'*"	sEz	"r   c                   "   \         h5ir3   r   )r:   r   r   s   &&&r   r   FileIOWrapperBase.readline   s      "!r   c                $   < V ^8  d   QhRS[ RR/# )r   r   r   Nr   )r   r0   s   "r   r   r      s      3 4 r   c                    Wn         R # r3   r   )r:   r   s   &&r   r   FileIOWrapperBase.seek   s    r   c                    < V ^8  d   QhRS[ /# r>   r   )r   r0   s   "r   r   r      s      c r   c                    V P                   # r3   r   rO   s   &r   tellFileIOWrapperBase.tell   s    ||r   c                $   < V ^8  d   QhRS[ RR/# )r   sync_metadatar   N)bool)r   r0   s   "r   r   r      s     % % %$ %r   c                   "   V'       d%   V P                   P                  4       G R j  xL
  R # V P                   P                  4       G R j  xL
  R #  L* L5ir3   )r9   fsyncfdsync)r:   r   s   &&r   flushFileIOWrapperBase.flush   s:     ))//###))""$$$ $$s!   &AA#AAAAc                   < V ^8  d   QhRR/# )r   r   NrM   )r   r0   s   "r   r   r      s        T  r   c                V   "   V P                   P                  4       G R j  xL
  R #  L5ir3   )r9   r   rO   s   &r   r   FileIOWrapperBase.close   s     iioo   )')c                .   < V ^8  d   QhRS[ R,          /# )r   r   )NNr   )r   )r   r0   s   "r   r   r      s      9%DE r   c              #  V   "   V P                   P                  4        R j  xL
  V #  L5ir3   )r9   	__await__rO   s   &r   r   FileIOWrapperBase.__await__   s%     99&&((( 	)r   c                   < V ^8  d   QhRR/# )r   r   r   rM   )r   r0   s   "r   r   r      s      "5 r   c                V   "   V P                   P                  4       G R j  xL
  V #  L5ir3   )r9   openrO   s   &r   
__aenter__FileIOWrapperBase.__aenter__   s#     iinn 	r   c                $   < V ^8  d   QhRS[ RR/# )r   _r   N)r   )r   r0   s   "r   r   r      s      # $ r   c                B   "   V P                  4       G R j  xL
  R #  L5ir3   )r   )r:   r   s   &*r   	__aexit__FileIOWrapperBase.__aexit__   s     jjls   c                    < V ^8  d   QhRS[ /# r>   )rs   )r   r0   s   "r   r   r      s     % %: %r   c                ,    \        V P                  4      # r3   )rs   r9   rO   s   &r   rP   FileIOWrapperBase.__aiter__   s    $))$$r   c                &   < V ^8  d   QhRS[ RS[/# )r   r   r   )r   r,   )r   r0   s   "r   r   r      s     M Ms M6 Mr   c                D    \        V P                  WP                  R 7      # )rz   )r,   r9   r   )r:   r   s   &&r   iter_chunkedFileIOWrapperBase.iter_chunked   s    diiJ||LLr   )r   r   r9   Nr   )r   .)F)rU   rV   rW   rX   _READLINE_CHUNK_SIZEr;   r   r   r   r   r   r   r   r   r   r   r   rP   r,   rZ   r   r[   r\   r]   s   @r   r   r      s     	!a 	! 	! " " " " " " " "
  % %      % % .4->-> M M Mr   r   c                      a a ] tR t^t oV3R lV 3R l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RV3R	 lR
 lltRt	Vt
V ;t# )BinaryFileWrapperc                    < V ^8  d   QhRS[ /# r   r   r   )r   r0   s   "r   r   BinaryFileWrapper.__annotate__   s      G r   c                t   < VP                   P                  '       g   \        R 4      h\        SV `  V4       R# )zExpected file in binary modeN)rC   rD   
ValueErrorsuperr;   r:   r   	__class__s   &&r   r;   BinaryFileWrapper.__init__   s)    xx;<<r   c                &   < V ^8  d   QhRS[ RS[/# r   r   r@   )r   r0   s   "r   r   r      s      3 5 r   c                   "   V P                   P                  WP                  4      G R j  xL
 pV ;P                  \        V4      ,          un        V#  L(5ir3   )r9   r   r   r   )r:   r   rh   s   && r   __readBinaryFileWrapper.__read   s=     YY))&,,??D	! @s   )AA)Ac                &   < V ^8  d   QhRS[ RS[/# r   r   )r   r0   s   "r   r   r      s     - - -e -r   c                   "   V P                   ;_uu_4       GR j  xL
  V P                  V4      G R j  xL
 uuR R R 4      GR j  xL
  #  L/ L L	  + GR j  xL 
 '       g   i     R # ; i5ir3   )r   _BinaryFileWrapper__readr   s   &&r   r   BinaryFileWrapper.read   6     ::::V,, ::, :::Y   A.AA.AAAA.AA.AA.A+	A
A+	#A+	%	A.c                &   < V ^8  d   QhRS[ RS[/# r   )r@   r   )r   r0   s   "r   r   r      s       # r   c                `  "   V P                   ;_uu_4       GR j  xL
  V P                  P                  WP                  4      pV ;P                  \	        V4      ,          un        R R R 4      GR j  xL
  XG R j  xL
  \	        V4      #  Lp L  + GR j  xL 
 '       g   i     L2; i L/5ir3   )r   r9   rl   r   r   )r:   rh   	operations   && r   r   BinaryFileWrapper.write   se     ::::		--dLLAILLCI%L : 4y	 ::: 	sW   B.BB.AB'B.2B3	B.<B,=B.B.B)	B
B)	"B)	$	B.c                ,   < V ^8  d   QhRS[ RS[RS[/# r   r   )r   r0   s   "r   r   r      s"        3  e    r   c           	     n  "   V P                   ;_uu_4       GR j  xL
  V P                  p\        P                  ! 4       ;_uu_ 4       p V P	                  V P
                  4      G R j  xL
 pV'       d+   W%9  d   VP                  V4       KE  VP                  V4       ^ Tu;8  d   VP                  4       8:  dR   M MNVP                  V4       VP                  V4       VP                  4       uuR R R 4       uuR R R 4      GR j  xL
  # VP                  ^ 4       VP                  4       pW4P                  4       ,           V n        TuuR R R 4       uuR R R 4      GR j  xL
  #  ELM EL Le L  + '       g   i     M; iR R R 4      GR j  xL 
  R #   + GR j  xL 
 '       g   i     R # ; i5ir3   )r   r   r|   r}   r   r   r   r   r   r   getvaluer   r:   r   r   r   fpr(   r   s   &&&    r   r   BinaryFileWrapper.readline   s     ::::\\F"&++d.G.G"HHE"/HHUO$4,2779,D)!{{}  ::$ GGAJ;;=D#)GGI#5DL'  :: I	  :::::s   F5E(F5*F	 E2	)E+*E2	6A;E2	1
F;F5E.	F5=E2	
FF5"E0#F5+E2	.F50F52F=FF5FF5F2	F!
F2	*F2	,	F5r   r   )r      
)rU   rV   rW   rX   r;   r   r   r   r   r[   r\   __classcell__r   r0   s   @@r   r   r      s<      
 
- -      r   r   c                      a a ] tR tRt oV3R lV 3R l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RV3R
 lR lltRt	Vt
V ;t# )TextFileWrapperi  c                    < V ^8  d   QhRS[ /# r   r   )r   r0   s   "r   r   TextFileWrapper.__annotate__  s     + +G +r   c                   < VP                   P                  '       d   \        R 4      h\        SV `  V4       V P
                  P                  V n        R# )zExpected file in text modeN)rC   rD   r   r   r;   r9   r   r   s   &&r   r;   TextFileWrapper.__init__  s:    88???9::		**r   c                &   < V ^8  d   QhRS[ RS[/# r   r   r   )r   r0   s   "r   r   r
    s      3 3 r   c                (  "   ^ pV P                   pRpV^ 8  g   V\        V4      8  dG   \        V P                  WV P                  4      G Rj  xL
 w  rVV'       g   MWF,          pW5,          pK]  Y!u;8  d   ^ 8  d   M MVRV pTpW0n         V#  LA5i)r    N)r   r   r*   r9   r   )r:   r   r   r   r(   part_offsetparts   &&     r   r   TextFileWrapper.__read  s     
qjFSZ/&4		64==' !K ME!F""'6NEF!s   ABBABc                &   < V ^8  d   QhRS[ RS[/# r   r  )r   r0   s   "r   r   r
  (  s     - - -c -r   c                   "   V P                   ;_uu_4       GR j  xL
  V P                  V4      G R j  xL
 uuR R R 4      GR j  xL
  #  L/ L L	  + GR j  xL 
 '       g   i     R # ; i5ir3   )r   _TextFileWrapper__readr   s   &&r   r   TextFileWrapper.read(  r   r   c                &   < V ^8  d   QhRS[ RS[/# r   )r   r   )r   r0   s   "r   r   r
  ,  s        r   c                  "   V P                   ;_uu_4       GR j  xL
  VP                  V P                  4      pV P                  P	                  W P
                  4      pV ;P
                  \        V4      ,          un        R R R 4      GR j  xL
  XG R j  xL
  \        X4      #  L L  + GR j  xL 
 '       g   i     L2; i L/5ir3   )r   encoder   r9   rl   r   r   )r:   rh   
data_bytesr   s   &&  r   r   TextFileWrapper.write,  sw     ::::T]]3J		--j,,GILLC
O+L :
 : :::
 	sW   C	B'C	A#B+C	B)	C	CC	)C	+C	1B42
C	=C	?	C	c                ,   < V ^8  d   QhRS[ RS[RS[/# r   r  )r   r0   s   "r   r   r
  5  s"        3  c  S  r   c                  "   V P                   ;_uu_4       GR j  xL
  V P                  p\        P                  ! 4       ;_uu_ 4       p V P	                  V P
                  4      G R j  xL
 pV'       d+   W%9  d   VP                  V4       KE  VP                  V4       ^ Tu;8  d   VP                  4       8:  dR   M MNVP                  V4       VP                  V4       VP                  4       uuR R R 4       uuR R R 4      GR j  xL
  # VP                  ^ 4       VP                  4       pV\        VP                  V P                  R7      4      ,           V n        TuuR R R 4       uuR R R 4      GR j  xL
  #  ELc EL L{ L  + '       g   i     M; iR R R 4      GR j  xL 
  R #   + GR j  xL 
 '       g   i     R # ; i5irB   )r   r   r|   r~   r  r   r   r   r   r   r   r   r   r  r   r  s   &&&    r   r   TextFileWrapper.readline5  s    ::::\\F""&++d.G.G"HHE"/HHUO$4,2779,D)!{{}  ::$ GGAJ;;=D#)CT]];- $DL  +  :: I	  :::::s   GE>G*F.	 F	)F*F	6A;F	1
F.;GF	GAF	!
F.+G8F9GF	GGFF.G&F)'G.G	4F75
G	 G		G)r   r   r   )r   ru   )rU   rV   rW   rX   r;   r  r   r   r   r[   r\   r  r  s   @@r   r  r    s<     + + ,- -      r   r  c                    V ^8  d   QhR\         \        \        \        3,          R\        R\        R\        R\         \
        \        3,          /# )r   file_specifierrC   argskwargsr   )r
   r   r   r   r   r   r  )r   s   "r   r   r   P  sM     " "#tZ/0"
""+." o-."r   c                 &   \        V \        \        34      '       d   \        \        V 4      V.VO5/ VB pM*V'       d   \	        R 4      h\        P
                  ! V 3/ VB pVP                  P                  '       g   \        V4      # \        V4      # )z&Arguments denied when IO[Any] opening.)
rj   r   r   r   r   from_fprC   rD   r  r   )r!  rC   r"  r#  r   s   &&*, r   
async_openr&  P  su     .3+..c.)4A$A&AEFFoon7788???s##S!!r   )r   )r)r   r   rs   r,   r  r_   r&  r*   )r4   collections.abccollectionsr|   r   abcr   r   pathlibr   typesr   typingr   r   r	   r
   aior   r   r"   r*   AsyncIterabler,   r_   rs   r   r   r  r&  __all__rM   r   r   <module>r1     s      	 	 #  " / / $  QaQa	! 0)[__** )X' '"2.. 2j:M :Mz, ) , ^B ' B J""	r   