
    m*iD                        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
             \/var/www/html/land-doc-ocr/venv/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&   B   sf      |'')	

B ""800Ax00 	1s   AAAAc                $    SU  S3n[        U5      e)NzUnsupported io type: .)	TypeError)r'   r   r   msgs       r(   r/   r/   b   s    !$q
)C
C.r)   c                    [        XUS9$ Nr   )r   r'   r   r   s      r(   _r9   h   s    dAAr)   c                    [        XUS9$ r7   )r   r8   s      r(   r9   r9   m        tBBr)   c                    [        XUS9$ r7   )r   r8   s      r(   r9   r9   s   r;   r)   c                    [        XUS9$ r7   )r   r8   s      r(   r9   r9   y   s    t::r)   z	sys.stdinc                  "    [         R                  $ N)sysr    r)   r(   <lambda>rB   ~   s    SYYr)   )indirectz
sys.stdoutc                  "    [         R                  $ r?   )r@   r   rA   r)   r(   rB   rB          szzr)   z
sys.stderrc                  "    [         R                  $ r?   )r@   r   rA   r)   r(   rB   rB      rE   r)   zsys.stdin.bufferc                  6    [         R                  R                  $ r?   )r@   r   bufferrA   r)   r(   rB   rB      s    SYY5E5Er)   zsys.stdout.bufferc                  6    [         R                  R                  $ r?   )r@   r   rH   rA   r)   r(   rB   rB          cjj6G6Gr)   zsys.stderr.bufferc                  6    [         R                  R                  $ r?   )r@   r   rH   rA   r)   r(   rB   rB      rJ   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/   registerr9   r   r   r   r   r   r   rA   r)   r(   <module>rV      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)   