
    i                         S SK Jr  S SKJr  S SKJr  S SKJrJr  S r	 " S S5      r
 " S S	\
5      r " S
 S\\5      rg)    )get_running_loop)	Awaitable)AbstractAsyncContextManager)partialwrapsc                 :   ^  [        T 5      S S S.U 4S jj5       nU$ )N)loopexecutorc                 z   >#    U c
  [        5       n [        T/UQ70 UD6nU R                  X5      I S h  vN $  N7fN)r   r   run_in_executor)r	   r
   argskwargspfuncfuncs        U/var/www/html/qgis-automation/mouza_env/lib/python3.13/site-packages/aiofiles/base.pyrunwrap.<locals>.run   s>     <#%D.t.v.))(::::s   1;9;)r   )r   r   s   ` r   wrapr      s%    
4["T ; ; J    c                   J   ^  \ rS rSrS r\S 5       rS rU 4S jrS r	Sr
U =r$ )	AsyncBase   c                 (    Xl         X0l        X l        g r   )_file	_executor	_ref_loop)selffiler	   r
   s       r   __init__AsyncBase.__init__   s    
!r   c                 <    U R                   =(       d
    [        5       $ r   )r   r   r   s    r   _loopAsyncBase._loop   s    ~~3!1!33r   c                     U $ )zWe are our own iterator. r#   s    r   	__aiter__AsyncBase.__aiter__   s    r   c                 R   > [         TU ]  5       S-   [        U R                  5      -   $ )Nz
 wrapping )super__repr__reprr   )r   	__class__s    r   r,   AsyncBase.__repr__    s$    w!L04

3CCCr   c                 \   #    U R                  5       I Sh  vN =n(       a  U$ [        e N7f)zSimulate normal file iteration.N)readlineStopAsyncIteration)r   lines     r   	__anext__AsyncBase.__anext__#   s+      ((4(K   )s   ,*,)r   r   r   )__name__
__module____qualname____firstlineno__r    propertyr$   r(   r,   r4   __static_attributes____classcell__r.   s   @r   r   r      s1    
 4 4D! !r   r   c                   \   ^  \ rS rSrU 4S jr\S 5       r\R                  S 5       rSrU =r	$ )AsyncIndirectBase+   c                 >   > X@l         Xl        [        TU ]  S X#5        g r   )	_indirect_namer+   r    )r   namer	   r
   indirectr.   s        r   r    AsyncIndirectBase.__init__,   s    !
t.r   c                 "    U R                  5       $ r   )rB   r#   s    r   r   AsyncIndirectBase._file1   s    ~~r   c                     g r   r'   )r   vs     r   r   rH   5   s    r   )rB   rC   )
r6   r7   r8   r9   r    r:   r   setterr;   r<   r=   s   @r   r?   r?   +   s4    /
     \\ r   r?   c                   4    \ rS rSrSrSrS rS rS rS r	Sr
g)	AiofilesContextManager:   z/An adjusted async context manager for aiofiles._coro_objc                     Xl         S U l        g r   rO   )r   coros     r   r    AiofilesContextManager.__init__?   s    
	r   c              #      #    U R                   c'  U R                  R                  5        S h  vN U l         U R                   $  N7fr   )rQ   rP   	__await__r#   s    r   rV    AiofilesContextManager.__await__C   s5     99#'::#7#7#99DIyy :s   +AAAc                 "   #    U I S h  vN $  N7fr   r'   r#   s    r   
__aenter__!AiofilesContextManager.__aenter__H   s     zzs   c                    #    [        5       R                  S U R                  R                  R                  XU5      I S h  vN   S U l        g  N7fr   )r   r   rQ   r   __exit__)r   exc_typeexc_valexc_tbs       r   	__aexit__ AiofilesContextManager.__aexit__K   sE      00$))//**Hv
 	
 	
 		
s   >A AAN)r6   r7   r8   r9   __doc__	__slots__r    rV   rY   r`   r;   r'   r   r   rM   rM   :   s    9!I
r   rM   N)asyncior   collections.abcr   
contextlibr   	functoolsr   r   r   r   r?   rM   r'   r   r   <module>rh      s;    $ % 2 $! !2	 Y(C r   