
    Ng=                        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mZmZmZ dd	lmZmZ eZd
Z	 	 	 	 	 	 	 d#ddddZ	 	 	 	 	 	 	 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   )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
             X/var/www/html/ai-engine/env/lib/python3.11/site-packages/aiofiles/threadpool/__init__.pyr   r   $   sF     "	
 	
 	
      c                   K   |t          j                    }t          t          | |||||||	  	        }
|                    |	|
           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(   A   s       |'))	

 

 

B ""8R00000000Ax0000r+   c                F    t          d                    |                     )NzUnsupported io type: {}.)	TypeErrorformatr)   r   r   s      r*   r1   r1   a   s    
.55d;;
<
<<r+   c                &    t          | ||          S Nr   )r   r7   s      r*   _r:   f   s    dAAAAr+   c                &    t          | ||          S r9   )r   r7   s      r*   r:   r:   k        t$BBBBr+   c                &    t          | ||          S r9   )r   r7   s      r*   r:   r:   q   r<   r+   c                &    t          | ||          S r9   )r   r7   s      r*   r:   r:   w   s    t$::::r+   z	sys.stdinc                      t           j        S N)sysr    r+   r*   <lambda>rC   |   s    SY r+   )indirectz
sys.stdoutc                      t           j        S r@   )rA   r   rB   r+   r*   rC   rC   ~       sz r+   z
sys.stderrc                      t           j        S r@   )rA   r   rB   r+   r*   rC   rC      rF   r+   zsys.stdin.bufferc                  $    t           j        j        S r@   )rA   r   bufferrB   r+   r*   rC   rC      s    SY5E r+   zsys.stdout.bufferc                  $    t           j        j        S r@   )rA   r   rI   rB   r+   r*   rC   rC          cj6G r+   zsys.stderr.bufferc                  $    t           j        j        S r@   )rA   r   rI   rB   r+   r*   rC   rC      rK   r+   )r   r   NNNTN)$__doc__r-   rA   	functoolsr   r   ior   r   r   r   r	   r
   baser   binaryr   r   r   r   textr   r   r   r/   __all__r(   r1   registerr:   r   r   r   r   r   r   rB   r+   r*   <module>rU      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+   