
    ic                        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j=                  e      dddd       Zej=                  e
      ej=                  e      dddd              Zej=                  e	      ej=                  e      dddd              Zej=                  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%y)"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loopexecutorc                >    t        t        | |||||||||	
            S )N)	mode	bufferingencodingerrorsnewlineclosefdopenerr   r   )r   _open)
filer    r!   r"   r#   r$   r%   r&   r   r   s
             p/var/www/catia.catastroantioquia-mas.com/valormasv2/lib/python3.12/site-packages/aiofiles/threadpool/__init__.pyr   r   %   s7     "	
     c             #      K   |t        j                         }t        t        | |||||||	      }
|j	                  |	|
      E d{   }t        |||	      S 7 w)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   sk      |'')	

B ''"55Ax00 	6s   AAAAc                6    t        dj                  |             )NzUnsupported io type: {}.)	TypeErrorformatr(   r   r   s      r)   r0   r0   c   s    
.55d;
<<r*   c                    t        | ||      S Nr   )r   r6   s      r)   _r9   h   s    dAAr*   c                    t        | ||      S r8   )r   r6   s      r)   r9   r9   m        t$BBr*   c                    t        | ||      S r8   )r   r6   s      r)   r9   r9   s   r;   r*   c                    t        | ||      S r8   )r   r6   s      r)   r9   r9   y   s    t$::r*   z	sys.stdinc                  "    t         j                  S N)sysr    r*   r)   <lambda>rB   ~   s
    SYY r*   )indirectz
sys.stdoutc                  "    t         j                  S r?   )r@   r   rA   r*   r)   rB   rB      
    szz r*   z
sys.stderrc                  "    t         j                  S r?   )r@   r   rA   r*   r)   rB   rB      rE   r*   zsys.stdin.bufferc                  6    t         j                  j                  S r?   )r@   r   bufferrA   r*   r)   rB   rB      s    SYY5E5E r*   zsys.stdout.bufferc                  6    t         j                  j                  S r?   )r@   r   rH   rA   r*   r)   rB   rB          cjj6G6G r*   zsys.stderr.bufferc                  6    t         j                  j                  S r?   )r@   r   rH   rA   r*   r)   rB   rB      rJ   r*   )rNNNTN)&__doc__r,   r@   	functoolsr   r   ior   r   r   r   r	   r
   typesr   baser   binaryr   r   r   r   textr   r   r   r.   __all__r'   r0   registerr9   r   r   r   r   r   r   rA   r*   r)   <module>rW      s   0  
 -   )  A	 
 
:  
1 
1 1@ d = = z4 B B ~~4 C  C ~~4 C  C v4 ; ; 	#;dEVW	#$'9
 
$$'9
 *d-E +t.G +t.Gr*   