o
    LDiD                     @   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mZmZmZ dd	lmZmZ eZd
Z							d(dddddZ							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   )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(   h/var/www/www-root/data/www/77.83.87.30/venv/lib/python3.10/site-packages/aiofiles/threadpool/__init__.pyr   %   s   r   c                   sL   |du r	t  }tt| |||||||d	}
||	|
I dH }t|||	d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fr(   r(   r)   r&   B   s    r&   c                C   s   d|  d}t |)NzUnsupported io type: .)	TypeError)r'   r   r   msgr(   r(   r)   r.   b   s   r.   c                C      t | ||dS Nr   )r   r'   r   r   r(   r(   r)   _h      r7   c                C   r4   r5   )r   r6   r(   r(   r)   r7   m      c                C   r4   r5   )r   r6   r(   r(   r)   r7   s   r9   c                C   r4   r5   )r   r6   r(   r(   r)   r7   y   r8   z	sys.stdinc                   C      t jS N)sysr   r(   r(   r(   r)   <lambda>~       r=   )indirectz
sys.stdoutc                   C   r:   r;   )r<   r   r(   r(   r(   r)   r=      r>   z
sys.stderrc                   C   r:   r;   )r<   r   r(   r(   r(   r)   r=      r>   zsys.stdin.bufferc                   C      t jjS r;   )r<   r   bufferr(   r(   r(   r)   r=          zsys.stdout.bufferc                   C   r@   r;   )r<   r   rA   r(   r(   r(   r)   r=      rB   zsys.stderr.bufferc                   C   r@   r;   )r<   r   rA   r(   r(   r(   r)   r=      rB   )r   r   NNNTN)$__doc__r*   r<   	functoolsr   r   ior   r   r   r   r   r	   baser   binaryr   r   r   r   textr   r   r   r,   __all__r&   r.   registerr7   r   r   r   r   r   r   r(   r(   r(   r)   <module>   sx     	

 
