Ë
    |¾�j{  ã                   óœ   — d Z ddlmZ ddlmZ 	 ddlmZ dd„Z G d	„ d
«      Z	 G d„ d«      Z
d„ Zy# e$ r ddlmZ  G d„ de«      ZY Œ4w xY w)z'Patches for async socket functionality.é    ©Úasynccontextmanager)Úpatch)Ú	AsyncMock)Ú	MagicMockc                   ó   ‡ — e Zd Zˆ fd„Zˆ xZS )r   c              �   ó2   •K  — t        t        | �
  |i |¤ŽS ­w©N)Úsuperr   Ú__call__)ÚselfÚargsÚkwargsÚ	__class__s      €úT/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/test_async/patchers.pyr   zAsyncMock.__call__   s   øè ø€ Üœ DÑ2°DÐC¸FÑCÐCùs   ƒ)Ú__name__Ú
__module__Ú__qualname__r   Ú__classcell__)r   s   @r   r   r      s   ø„ ÷	Dð 	Dó    r   c                 óB   ‡ ‡‡—  G ˆfd„d«      Št         ˆˆ fd„«       Š‰S )Nc                   ó*   •— e Zd Zˆ fd„Zdd„Zˆ fd„Zy)ú&async_mock_open.<locals>.AsyncMockFilec                 ó(   •— || _         |d d ‰_        y )Nr   )Ú	read_dataÚwritten)r   r   Ú_async_mock_opens     €r   Ú__init__z/async_mock_open.<locals>.AsyncMockFile.__init__   s   ø€ Ø&ˆDŒNØ'0°°! }ÐÕ$r   c              “   óà   K  — |dk(  r"| j                   }| j                   d d | _         |S t        |t        | j                   «      «      }| j                   d | }| j                   |d  | _         |S ­w)Néÿÿÿÿr   )r   ÚminÚlen)r   ÚsizeÚretÚns       r   Úreadz+async_mock_open.<locals>.AsyncMockFile.read   si   è ø€ Ø�rŠzØ—n‘n�Ø!%§¡°°Ð!3�”Ø�
ä�Dœ#˜dŸn™nÓ-Ó.ˆAØ—.‘.  !Ð$ˆCØ!Ÿ^™^¨A¨BÐ/ˆDŒNØˆJùs   ‚A,A.c              “   ó`   •K  — ‰j                   r‰xj                   |z  c_         y |‰_         y ­wr
   )r   )r   Úbr   s     €r   Úwritez,async_mock_open.<locals>.AsyncMockFile.write!   s*   øè ø€ Ø×'Ò'Ø ×(Ò(¨AÑ-Ö(à+,Ð Õ(ùs   ƒ+.N)r    )r   r   r   r   r&   r)   )r   s   €r   ÚAsyncMockFiler      s   ø„ ô	5ó		õ	-r   r*   c                 ó0   •K  — 	  ‰‰«      ­–— y # w xY w­wr
   © )r   r   r*   r   s     €€r   r   z)async_mock_open.<locals>._async_mock_open'   s   øè ø€ ð	Ù 	Ó*Ó*àøˆDüs   ƒ… �‘“r   )r   r*   r   s   `@@r   Úasync_mock_openr-      s)   ú€ ÷-ó -ô, ôó ðð Ðr   c                   ó$   — e Zd Zd„ Zd„ Zd„ Zd„ Zy)ÚFakeStreamWriterc                  ó   — y r
   r,   ©r   s    r   ÚclosezFakeStreamWriter.close2   ó   € Ør   c              ƒ   ó   K  — y ­wr
   r,   r1   s    r   Úwait_closedzFakeStreamWriter.wait_closed5   ó	   è ø€ Øùó   ‚c                  ó   — y r
   r,   )r   Údatas     r   r)   zFakeStreamWriter.write8   r3   r   c              ƒ   ó   K  — y ­wr
   r,   r1   s    r   ÚdrainzFakeStreamWriter.drain;   r6   r7   N)r   r   r   r2   r5   r)   r;   r,   r   r   r/   r/   1   s   „ òòòór   r/   c                   ó   — e Zd Zd„ Zy)ÚFakeStreamReaderc              ƒ   ó   K  — y­w)Ns   TESTr,   )r   Únumbytess     r   r&   zFakeStreamReader.read@   s	   è ø€ Øùr7   N)r   r   r   r&   r,   r   r   r=   r=   ?   s   „ ór   r=   c                  ó$   — t        | dt        i|¤ŽS )NÚnew_callable)r   r   )r   r   s     r   Úasync_patchrB   D   s   € Ü�$Ð9¤YÐ9°&Ñ9Ð9r   N)Ú )Ú__doc__Ú
contextlibr   Úunittest.mockr   r   ÚImportErrorr   r-   r/   r=   rB   r,   r   r   ú<module>rH      s[   ðÙ -å *Ý ðDÝ'ó÷Bñ ÷ñ ó
:øðy ò DÝ'ôD�Iö DðDús   �2 ²AÁ
A