
     ic                     8   d Z ddlZddlZddlmZmZ ddlmZmZm	Z	m
Z
mZmZ ddlmZ ddlmZ dd	lmZmZmZmZ dd
lmZmZ eZdZ	 	 	 	 	 	 	 d$ddddZe	 	 	 	 	 	 	 d$dddd            Zedddd            Ze                    e          dddd            Ze                    e
          e                    e          dddd                        Ze                    e	          e                    e          dddd                        Ze                    e          dddd            Z edddd           Z  edddd           Z! edddd           Z" edddd           Z# ed ddd!           Z$ ed"ddd#           Z%dS )%z*Handle files using a thread pool executor.    N)partialsingledispatch)BufferedIOBaseBufferedRandomBufferedReaderBufferedWriterFileIO
TextIOBase)	coroutine   )AiofilesContextManager   )AsyncBufferedIOBaseAsyncBufferedReaderAsyncFileIOAsyncIndirectBufferedIOBase)AsyncTextIndirectIOWrapperAsyncTextIOWrapper)openstdinstdoutstderrstdin_bytesstdout_bytesstderr_bytesrTloopexecutorc                N    t          t          | |||||||||	
  
                  S )N)	mode	bufferingencodingerrorsnewlineclosefdopenerr   r    )r   _open)
filer"   r#   r$   r%   r&   r'   r(   r   r    s
             d/root/.openclaw/workspace/.venvs/songid/lib/python3.11/site-packages/aiofiles/threadpool/__init__.pyr   r   %   sF     "	
 	
 	
      c             #      K   |t          j                    }t          t          | |||||||	  	        }
|                    |	|
          E d{V }t          |||	          S )zOpen an asyncio file.N)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   s       |'))	

 

 

B ''"55555555Ax0000r,   c                F    t          d                    |                     )NzUnsupported io type: {}.)	TypeErrorformatr*   r   r    s      r+   r2   r2   c   s    
.55d;;
<
<<r,   c                &    t          | ||          S Nr   )r   r8   s      r+   _r;   h   s    dAAAAr,   c                &    t          | ||          S r:   )r   r8   s      r+   r;   r;   m        t$BBBBr,   c                &    t          | ||          S r:   )r   r8   s      r+   r;   r;   s   r=   r,   c                &    t          | ||          S r:   )r   r8   s      r+   r;   r;   y   s    t$::::r,   z	sys.stdinc                      t           j        S N)sysr    r,   r+   <lambda>rD   ~   s    SY r,   )indirectz
sys.stdoutc                      t           j        S rA   )rB   r   rC   r,   r+   rD   rD          sz r,   z
sys.stderrc                      t           j        S rA   )rB   r   rC   r,   r+   rD   rD      rG   r,   zsys.stdin.bufferc                  $    t           j        j        S rA   )rB   r   bufferrC   r,   r+   rD   rD      s    SY5E r,   zsys.stdout.bufferc                  $    t           j        j        S rA   )rB   r   rJ   rC   r,   r+   rD   rD          cj6G r,   zsys.stderr.bufferc                  $    t           j        j        S rA   )rB   r   rJ   rC   r,   r+   rD   rD      rL   r,   )r   r   NNNTN)&__doc__r.   rB   	functoolsr   r   ior   r   r   r   r	   r
   typesr   baser   binaryr   r   r   r   textr   r   r   r0   __all__r)   r2   registerr;   r   r   r   r   r   r   rC   r,   r+   <module>rW      s   0 0  



 - - - - - - - -                      ) ) ) ) ) )            A @ @ @ @ @ @ @	 
 
    :  
1 
1 1 1 1 1@ d = = = = = z4 B B B B B ~~4 C C C C  C ~~4 C C C C  C v4 ; ; ; ; ; 	#";dEVEVWWW	#	#$'9'9
 
 
 
$	#$'9'9
 
 
 *)d-E-E   +*t.G.G   +*t.G.G  r,   