o
    -˜ŽjD  ã                   @   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ÚréÿÿÿÿT©Ú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(   úY/var/www/kodo/Anonymous/send/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     	ø
õø
õ ÿÿÿÿ
ÿ