
    q	h=                        S r SSKrSSKrSSKJrJr  SSKJrJrJ	r	J
r
JrJr  SSKJr  SSKJrJrJrJr  SS	KJrJr  \rS
r       S SSS.S jjr       S SSS.S jjr\SSS.S j5       r\R9                  \5      SSS.S j5       r\R9                  \
5      \R9                  \5      SSS.S j5       5       r\R9                  \	5      \R9                  \5      SSS.S j5       5       r\R9                  \5      SSS.S j5       r\" SSSS S9r\" SSSS S9r\" SSSS S9r \" SSSS S9r!\" SSSS S9r"\" SSSS S9r#g)!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loopexecutorc                8    [        [        U UUUUUUUUU	S9
5      $ )N)	mode	bufferingencodingerrorsnewlineclosefdopenerr   r   )r   _open)
filer   r    r!   r"   r#   r$   r%   r   r   s
             N/var/www/html/env/lib/python3.13/site-packages/aiofiles/threadpool/__init__.pyr   r   $   s7     "	
     c                   #    Uc  [         R                  " 5       n[        [        U UUUUUUUS9	n
UR	                  X5      I Sh  vN n[        XU	S9$  N7f)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&   A   sf      |'')	

B ""800Ax00 	1s   AAAAc                6    [        SR                  U 5      5      e)NzUnsupported io type: {}.)	TypeErrorformatr'   r   r   s      r(   r/   r/   a   s    
.55d;
<<r)   c                    [        XUS9$ Nr   )r   r5   s      r(   _r8   f   s    dAAr)   c                    [        XUS9$ r7   )r   r5   s      r(   r8   r8   k        tBBr)   c                    [        XUS9$ r7   )r   r5   s      r(   r8   r8   q   r:   r)   c                    [        XUS9$ r7   )r   r5   s      r(   r8   r8   w   s    t::r)   z	sys.stdinc                  "    [         R                  $ N)sysr    r)   r(   <lambda>rA   |   s    SYYr)   )indirectz
sys.stdoutc                  "    [         R                  $ r>   )r?   r   r@   r)   r(   rA   rA   ~       szzr)   z
sys.stderrc                  "    [         R                  $ r>   )r?   r   r@   r)   r(   rA   rA      rD   r)   zsys.stdin.bufferc                  6    [         R                  R                  $ r>   )r?   r   bufferr@   r)   r(   rA   rA      s    SYY5E5Er)   zsys.stdout.bufferc                  6    [         R                  R                  $ r>   )r?   r   rG   r@   r)   r(   rA   rA          cjj6G6Gr)   zsys.stderr.bufferc                  6    [         R                  R                  $ r>   )r?   r   rG   r@   r)   r(   rA   rA      rI   r)   )rNNNTN)$__doc__r+   r?   	functoolsr   r   ior   r   r   r   r	   r
   baser   binaryr   r   r   r   textr   r   r   r-   __all__r&   r/   registerr8   r   r   r   r   r   r   r@   r)   r(   <module>rU      s   0  
 -  *  A	 
 
> 
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)   