+
    ~j                         ^ RI Ht ^ RIHt ^ RIHt ^ RIHtHt R t	 ! R R4      t
 ! R R	]
4      t ! R
 R]]4      tR# )    )get_running_loop)	Awaitable)AbstractAsyncContextManager)partialwrapsc                 <   a  \        S 4      R RRR/V 3R ll4       pV# )loopNexecutorc                 |   <"   V f   \        4       p \        S.VO5/ VB pV P                  W4      G R j  xL
 #  L5iN)r   r   run_in_executor)r	   r
   argskwargspfuncfuncs   $$*, b/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/aiofiles/base.pyrunwrap.<locals>.run   s>     <#%D.t.v.))(::::s   2<:<)r   )r   r   s   f r   wrapr      s.    
4[;d ;T ; ; J    c                   T   a a ] tR t^t oR t]R 4       tR tV 3R ltR t	Rt
VtV ;t# )	AsyncBasec                *    Wn         W0n        W n        R # r   )_file	_executor	_ref_loop)selffiler	   r
   s   &&&&r   __init__AsyncBase.__init__   s    
!r   c                >    V P                   ;'       g    \        4       # r   )r   r   r   s   &r   _loopAsyncBase._loop   s    ~~33!1!33r   c                    V # )zWe are our own iterator. r"   s   &r   	__aiter__AsyncBase.__aiter__   s    r   c                b   < \         SV `  4       R ,           \        V P                  4      ,           # )z
 wrapping )super__repr__reprr   )r   	__class__s   &r   r+   AsyncBase.__repr__    s$    w!L04

3CCCr   c                ^   "   V P                  4       G Rj  xL
 ;p'       d   V# \        h L5i)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+   r3   __static_attributes____classdictcell____classcell__r-   __classdict__s   @@r   r   r      s3     
 4 4D! !r   r   c                   f   a a ] tR t^+t oV 3R lt]R 4       t]P                  R 4       tRtVt	V ;t
# )AsyncIndirectBasec                @   < W@n         Wn        \        SV `  R W#4       R # r   )	_indirect_namer*   r   )r   namer	   r
   indirectr-   s   &&&&&r   r   AsyncIndirectBase.__init__,   s    !
t.r   c                "    V P                  4       # r   )rB   r"   s   &r   r   AsyncIndirectBase._file1   s    ~~r   c                    R # r   r&   )r   vs   &&r   r   rH   5   s    r   )rB   rC   )r5   r6   r7   r8   r   r9   r   setterr:   r;   r<   r=   s   @@r   r@   r@   +   s;     /
     \\  r   r@   c                   @   a  ] tR t^:t o RtRtR tR tR tR t	Rt
V tR# )AiofilesContextManagerz/An adjusted async context manager for aiofiles.c                     Wn         R V n        R # r   _coro_obj)r   coros   &&r   r   AiofilesContextManager.__init__?   s    
	r   c              #     "   V P                   f(   V P                  P                  4        R j  xL
 V n         V P                   #  L5ir   )rQ   rP   	__await__r"   s   &r   rU    AiofilesContextManager.__await__C   s5     99#'::#7#7#99DIyy :s   ,AAAc                "   "   V G R j  xL
 #  L5ir   r&   r"   s   &r   
__aenter__!AiofilesContextManager.__aenter__H   s     zzs   c                   "   \        4       P                  R V P                  P                  P                  WV4      G R j  xL
  R V n        R #  L5i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rO   N)r5   r6   r7   r8   __doc__	__slots__r   rU   rX   r_   r:   r;   )r>   s   @r   rM   rM   :   s&     9!I
 r   rM   N)asyncior   collections.abcr   
contextlibr   	functoolsr   r   r   r   r@   rM   r&   r   r   <module>rg      s;    $ % 2 $! !2	 Y(C r   