U
    ;g=                     @   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(   \/opt/bot/vods_filmes/script/venv/lib/python3.8/site-packages/aiofiles/threadpool/__init__.pyr   $   s    r   c                   sJ   |dk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   )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&   A   s    r&   c                C   s   t d| d S )NzUnsupported io type: {}.)	TypeErrorformatr'   r   r   r(   r(   r)   r,   a   s    r,   c                C   s   t | ||dS Nr   )r   r1   r(   r(   r)   _f   s    r3   c                C   s   t | ||dS r2   )r   r1   r(   r(   r)   r3   k   s    c                C   s   t | ||dS r2   )r   r1   r(   r(   r)   r3   q   s    c                C   s   t | ||dS r2   )r   r1   r(   r(   r)   r3   w   s    z	sys.stdinc                   C   s   t jS N)sysr   r(   r(   r(   r)   <lambda>|       r6   )Zindirectz
sys.stdoutc                   C   s   t jS r4   )r5   r   r(   r(   r(   r)   r6   ~   r7   z
sys.stderrc                   C   s   t jS r4   )r5   r   r(   r(   r(   r)   r6      r7   zsys.stdin.bufferc                   C   s   t jjS r4   )r5   r   bufferr(   r(   r(   r)   r6      r7   zsys.stdout.bufferc                   C   s   t jjS r4   )r5   r   r8   r(   r(   r(   r)   r6      r7   zsys.stderr.bufferc                   C   s   t jjS r4   )r5   r   r8   r(   r(   r(   r)   r6      r7   )r   r   NNNTN)r   r   NNNTN)$__doc__r*   r5   	functoolsr   r   ior   r   r   r   r   r	   baser   binaryr   r   r   r   textr   r   r   r+   __all__r&   r,   registerr3   r   r   r   r   r   r   r(   r(   r(   r)   <module>   s    	       
       
                