Ë
    |¾�j~  ã                   óè   — d Z ddlZddlZddlZddlmZ ej                  j                  dd«       ddlm	Z	 ddl
mZ ddlmZmZmZ  G d	„ d
ej                   «      Zedk(  r ej&                  «        yy)z)Unit tests for `ConnectionAsync` class.

é    N)Úpatchz..)ÚConnectionAsyncé   )Úawaiter)ÚFakeStreamReaderÚFakeStreamWriterÚasync_patchc                   ó<   — e Zd Zed„ «       Zed„ «       Zed„ «       Zy)ÚTestConnectionAsyncc              ƒ   óÈ  K  — t        dt        «       t        «       f¬«      5  t        «       }|j	                  «       ƒ d {  –—†  | j                  |j                  «       | j                  |j                  «       d d d «       j                  «       ƒ d {  –—†  | j                  |j                  «       | j                  |j                  «       y 7 Œ‘# 1 sw Y   ŒZxY w7 ŒI­w)Núasyncio.open_connection©Úreturn_value)
r	   r   r   r   ÚconnectÚassertIsNotNoneÚreaderÚwriterÚcloseÚassertIsNone©ÚselfÚconns     úa/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/test_async/test_connection_async.pyÚtest_connect_closez&TestConnectionAsync.test_connect_close   s®   è ø€ äÐ2ÔBRÓBTÔVfÓVhÐAiÔjñ 	.Ü"Ó$ˆDØ—,‘,“.× Ð Ø× Ñ  §¡Ô-Ø× Ñ  §¡Ô-÷		.ð �j‰j‹l×ÐØ×Ñ˜$Ÿ+™+Ô&Ø×Ñ˜$Ÿ+™+Õ&ð !ø÷	.ð 	.úð 	ús:   ‚ C"¢CÁ CÁ:CÁ;C"ÂC Â;C"ÃCÃCÃC"c              ƒ   ó:  K  — t        dt        «       t        «       f¬«      5  t        «       }|j	                  «       ƒ d {  –—†  | j                  |j                  «       | j                  |j                  «       d d d «       t        dj                  t        «      t        ¬«      5  j                  «       ƒ d {  –—†  | j                  |j                  «       | j                  |j                  «       d d d «       y 7 Œ¾# 1 sw Y   Œ‡xY w7 ŒQ# 1 sw Y   y xY w­w)Nr   r   z{}.FakeStreamWriter.close©Úside_effect)r	   r   r   r   r   r   r   r   r   ÚformatÚ__name__ÚOSErrorr   r   r   s     r   Ú test_connect_close_catch_oserrorz4TestConnectionAsync.test_connect_close_catch_oserror    sÞ   è ø€ äÐ2ÔBRÓBTÔVfÓVhÐAiÔjñ 	.Ü"Ó$ˆDØ—,‘,“.× Ð Ø× Ñ  §¡Ô-Ø× Ñ  §¡Ô-÷		.ô Ð.×5Ñ5´hÓ?ÌWÔUñ 	+Ø—*‘*“,×ÐØ×Ñ˜dŸk™kÔ*Ø×Ñ˜dŸk™kÔ*÷	+ð 	+ð	 !ø÷	.ð 	.úð ø÷	+ð 	+üsX   ‚ D¢DÁ C?Á:DÁ;,DÂ'DÂ;DÂ<:DÃ6	DÃ?DÄD
ÄDÄDÄDÄDc              ƒ   ó  K  — | j                  t        «      5  t        dt        j                  ¬«      5  t        d¬«      }|j                  «       ƒ d {  –—†  d d d «       d d d «       y 7 Œ# 1 sw Y   ŒxY w# 1 sw Y   y xY w­w)Nr   r   r   )Útimeout)ÚassertRaisesÚRuntimeErrorr	   ÚasyncioÚTimeoutErrorr   r   r   s     r   Útest_connect_with_timeoutz-TestConnectionAsync.test_connect_with_timeout-   sr   è ø€ à×Ñœ|Ó,ñ 	%ÜÐ6ÄG×DXÑDXÔYñ %Ü&¨qÔ1�Ø—l‘l“n×$Ð$÷%÷	%ð 	%ð %ø÷%ð %ú÷	%ð 	%üsE   ‚B˜A8´ A,ÁA*ÁA,ÁA8Á!	BÁ*A,Á,A5	Á1A8Á8BÁ=BN)r   Ú
__module__Ú__qualname__r   r   r!   r(   © ó    r   r   r      s<   „ Øñ	'ó ð	'ð ñ
+ó ð
+ð ñ%ó ñ%r,   r   Ú__main__)Ú__doc__r&   ÚsysÚunittestÚunittest.mockr   ÚpathÚinsertÚppadb.connection_asyncr   Úasync_wrapperr   Úpatchersr   r   r	   ÚTestCaser   r   Úmainr+   r,   r   ú<module>r9      sc   ðñó
 Û 
Û Ý à ‡�‡���4Ô å 2å "ß EÑ Eô%˜(×+Ñ+ô %ðD ˆzÒØ€H‡M�M…Oð r,   