+
    ~jD                        R t ^ RIt^ RIt^ RIHt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HtHt ^RIHtHt ]tRtRRRRR/R	 lltRRRRR/R
 llt]RRRR/R l4       t]P9                  ]4      RRRR/R l4       t]P9                  ]
4      ]P9                  ]4      RRRR/R l4       4       t]P9                  ]	4      ]P9                  ]4      RRRR/R l4       4       t]P9                  ]4      RRRR/R l4       t]! RRRR R7      t]! RRRR R7      t]! RRRR R7      t ]! RRRR R7      t!]! RRRR R7      t"]! RRRR R7      t#R# )z*Handle files using a thread pool executor.N)partialsingledispatch)BufferedIOBaseBufferedRandomBufferedReaderBufferedWriterFileIO
TextIOBase)AiofilesContextManager)AsyncBufferedIOBaseAsyncBufferedReaderAsyncFileIOAsyncIndirectBufferedIOBase)AsyncTextIndirectIOWrapperAsyncTextIOWrapperloopexecutorc                >    \        \        V VVVVVVVVV	R 7
      4      # ))	mode	bufferingencodingerrorsnewlineclosefdopenerr   r   )r
   _open)
filer   r   r   r   r   r   r   r   r   s
   &&&&&&&&$$q/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/aiofiles/threadpool/__init__.pyopenr   %   s7     "	
     c                  "   Vf   \         P                  ! 4       p\        \        V VVVVVVVR7	      p
VP	                  W4      G Rj  xL
 p\        WV	R7      #  L5i)zOpen an asyncio file.N)r   r   r   r   r   r   r   r   r   )asyncioget_running_loopr   	sync_openrun_in_executorwrap)r   r   r   r   r   r   r   r   r   r   cbfs   &&&&&&&&$$  r   r   r   B   sf      |'')	

B ""800Ax00 	1s   AAA	Ac                $    R V  R2p\        V4      h)zUnsupported io type: .)	TypeError)r   r   r   msgs   &$$ r   r&   r&   b   s    !$q
)C
C.r   c                    \        WVR 7      # r!   )r   r   r   r   s   &$$r   _r0   h   s    dAAr   c                    \        WVR 7      # r.   )r   r/   s   &$$r   r0   r0   m        tBBr   c                    \        WVR 7      # r.   )r   r/   s   &$$r   r0   r0   s   r2   r   c                    \        WVR 7      # r.   )r   r/   s   &$$r   r0   r0   y   s    t::r   z	sys.stdinc                  "    \         P                  # N)sysstdin r   r   <lambda>r:   ~   s    SYYr   )indirectz
sys.stdoutc                  "    \         P                  # r6   )r7   stdoutr9   r   r   r:   r:          szzr   z
sys.stderrc                  "    \         P                  # r6   )r7   stderrr9   r   r   r:   r:      r>   r   zsys.stdin.bufferc                  6    \         P                  P                  # r6   )r7   r8   bufferr9   r   r   r:   r:      s    SYY5E5Er   zsys.stdout.bufferc                  6    \         P                  P                  # r6   )r7   r=   rB   r9   r   r   r:   r:          cjj6G6Gr   zsys.stderr.bufferc                  6    \         P                  P                  # r6   )r7   r@   rB   r9   r   r   r:   r:      rD   r   )r   r8   r=   r@   stdin_bytesstdout_bytesstderr_bytes)rNNNTN)$__doc__r"   r7   	functoolsr   r   ior   r   r   r   r   r	   baser
   binaryr   r   r   r   textr   r   r   r$   __all__r   r&   registerr0   r8   r=   r@   rF   rG   rH   r9   r   r   <module>rS      s   0  
 -  *  A	 
 :1 
1 1@ t d  
 zBD B4 B B ~~CD C4 C  C ~~CD C4 C  C v;D ;4 ; ; 	#;dEVW	#$'9
 
$$'9
 *d-E +t.G +t.Gr   