a
    x{Jhc                     @   s  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dZed*dddddZedddddZeedddddZee
eedddddZee	eedddddZeedddddZeddddd dZ edddd d dZ!ed!ddd"d dZ"ed#ddd$d dZ#ed%ddd&d dZ$ed'd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          
      C   s    t t| |||||||||	d
S )N)	mode	bufferingencodingerrorsnewlineclosefdopenerr   r   )r   _open)
filer    r!   r"   r#   r$   r%   r&   r   r    r)   N/var/www/shaz/venv/lib/python3.9/site-packages/aiofiles/threadpool/__init__.pyr   %   s    r   c                c   sJ   |du rt  }tt| |||||||d	}
||	|
E dH }t|||	dS )zOpen an asyncio file.N)r    r!   r"   r#   r$   r%   r&   r   )asyncioZget_running_loopr   	sync_openZrun_in_executorwrap)r(   r    r!   r"   r#   r$   r%   r&   r   r   cbfr)   r)   r*   r'   B   s    r'   c                C   s   t d| d S )NzUnsupported io type: {}.)	TypeErrorformatr(   r   r   r)   r)   r*   r-   c   s    r-   c                C   s   t | ||dS Nr   )r   r2   r)   r)   r*   _h   s    r4   c                C   s   t | ||dS r3   )r   r2   r)   r)   r*   r4   m   s    c                C   s   t | ||dS r3   )r   r2   r)   r)   r*   r4   s   s    c                C   s   t | ||dS r3   )r   r2   r)   r)   r*   r4   y   s    z	sys.stdinc                   C   s   t jS N)sysr   r)   r)   r)   r*   <lambda>~       r7   )Zindirectz
sys.stdoutc                   C   s   t jS r5   )r6   r   r)   r)   r)   r*   r7      r8   z
sys.stderrc                   C   s   t jS r5   )r6   r   r)   r)   r)   r*   r7      r8   zsys.stdin.bufferc                   C   s   t jjS r5   )r6   r   bufferr)   r)   r)   r*   r7      r8   zsys.stdout.bufferc                   C   s   t jjS r5   )r6   r   r9   r)   r)   r)   r*   r7      r8   zsys.stderr.bufferc                   C   s   t jjS r5   )r6   r   r9   r)   r)   r)   r*   r7      r8   )r   r   NNNTN)r   r   NNNTN)&__doc__r+   r6   	functoolsr   r   ior   r   r   r   r   r	   typesr
   baser   binaryr   r   r   r   textr   r   r   r,   __all__r'   r-   registerr4   r   r   r   r   r   r   r)   r)   r)   r*   <module>   sz           
       
 