ó
    Ð]j<  ã                  óÄ   • S r SSKJr  SSKrSSKJr  SSKJrJr  SSK	J
r  SSKJr  SS	KJr  \(       a  SS
KJr  \R$                  " S5      r " S S5      r " S S\5      rg)z.
Psycopg AsyncPipeline object implementation.
é    )ÚannotationsN)ÚTracebackType)ÚTYPE_CHECKINGÚAnyé   )Úerrors)ÚSelf)ÚBasePipeline)ÚAsyncConnectionÚpsycopgc                  ó8   • \ rS rSrSS jr        SS jrSrg)Ú
_DummyLocké   c              ƒ  ó   #   • g 7f©N© ©Úselfs    ÚT/home/mande/repo/quber/.venv/lib/python3.13/site-packages/psycopg/_pipeline_async.pyÚ
__aenter__Ú_DummyLock.__aenter__   s   é € Øùó   ‚c              ƒ  ó   #   • g 7fr   r   )r   Úexc_typeÚexc_valÚexc_tbs       r   Ú	__aexit__Ú_DummyLock.__aexit__   s
   é € ð 	ùr   r   N©ÚreturnÚNone©r   ztype[BaseException] | Noner   zBaseException | Noner   zTracebackType | Noner    r!   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r   Ú__static_attributes__r   ó    r   r   r      s2   † ôðà,ðð &ðð %ð	ð
 
÷r(   r   c                  ór   ^ • \ rS rSr% SrSrS\S'   SSU 4S jjjrSS jrSS jr        SS	 jr	S
r
U =r$ )ÚAsyncPipelineé$   z0Handler for (async) connection in pipeline mode.r   úAsyncConnection[Any]Ú_connc                ót   >• [         TU ]  U5        U(       a  [        5       U l        g UR                  U l        g r   )ÚsuperÚ__init__r   ÚlockÚ_lock)r   ÚconnÚ_no_lockÚ	__class__s      €r   r0   ÚAsyncPipeline.__init__*   s%   ø€ Ü‰Ñ˜ÔÞ%-”Z“\ˆ�
°4·9±9ˆ�
r(   c              ƒ  óT  #   •  U R                    ISh  v•N   U R                  R                  U R                  5       5      I Sh  v•N   SSS5      ISh  v•N   g NF N N	! , ISh  v•N  (       d  f       g= f! [        R
                   a  nUR                  S5      eSnAff = f7f)z[Sync the pipeline, send any pending command and receive and process
all available results.
N)r2   r-   ÚwaitÚ	_sync_genÚeÚ_NO_TRACEBACKÚwith_traceback)r   Úexs     r   ÚsyncÚAsyncPipeline.sync.   sk   é € ð	*Ø—z—z“zØ—j‘j—o‘o d§n¡nÓ&6Ó7×7Ð7÷ "—z’zÙ7÷ "—z—z�zûä�‰ó 	*Ø×#Ñ# DÓ)Ð)ûð	*üs‹   ‚B(„A; ”A•A; ˜-A!ÁAÁA!Á
A; ÁAÁA; ÁB(ÁA; ÁA!ÁA; Á!A8Á'A*Á(A8Á4A; Á7B(Á8A; Á;B%ÂB Â B%Â%B(c              ƒ  óü   #   • U R                    IS h  v•N   U R                  R                  U R                  5       5      I S h  v•N   S S S 5      IS h  v•N   U $  NG N N
! , IS h  v•N  (       d  f       U $ = f7fr   )r2   r-   r8   Ú
_enter_genr   s    r   r   ÚAsyncPipeline.__aenter__8   sM   é € Ø—:—:“:Ø—*‘*—/‘/ $§/¡/Ó"3Ó4×4Ð4÷ —:àˆñ Ù4÷ —:—:àˆüsV   ‚A<“A”A<—-A!ÁAÁA!Á	A<ÁAÁA<ÁA!ÁA<Á!A9Á'A*Á(A9Á4A<c              ƒ  óÒ  #   •  U R                    IS h  v•N   U R                  R                  U R                  5       5      I S h  v•N   S S S 5      IS h  v•N   U R                  U5        g  NW N( N! , IS h  v•N  (       d  f       N/= f! [         a8  nU(       a  [
        R                  SX5         S nAN^UR                  S 5      eS nAff = f! U R                  U5        f = f7f)Nz error ignored terminating %r: %s)	r2   r-   r8   Ú	_exit_genÚ	ExceptionÚloggerÚwarningr<   Ú_exit)r   r   r   r   Úexc2s        r   r   ÚAsyncPipeline.__aexit__=   sœ   é € ð
	 Ø—z—z“zØ—j‘j—o‘o d§n¡nÓ&6Ó7×7Ð7÷ "—zð �J‰J�wÕñ "Ù7÷ "—z—z�zûäó 	0æÜ—‘ÐAÀ4×NÑNà×)Ñ)¨$Ó/Ð/ûð	0ûð �J‰J�wÕüs£   ‚C'„B ”A,•B ˜-A2ÁA.ÁA2Á
B ÁA0ÁB ÁC'Á,B Á.A2Á0B Á2B	Á8A;Á9B	ÂB ÂC Â	B Â
CÂC	Â3C Â8C	Ã	CÃC ÃC$Ã$C')r2   )F)r3   r,   r4   Úboolr    r!   r   )r    r	   r"   )r#   r$   r%   r&   Ú__doc__Ú__annotations__r0   r>   r   r   r'   Ú__classcell__)r5   s   @r   r*   r*   $   sU   ø‡ Ù:à€JØÓ÷=ñ =ô*ôð
 à,ð ð &ð ð %ð	 ð
 
÷ ò  r(   r*   )rL   Ú
__future__r   ÚloggingÚtypesr   Útypingr   r   Ú r   r:   Ú_compatr	   Ú_pipeline_baser
   Úconnection_asyncr   Ú	getLoggerrF   r   r*   r   r(   r   Ú<module>rX      sM   ðñõ #ã Ý ß %å Ý Ý (æÝ1à	×	Ò	˜9Ó	%€÷
ñ 
ô) �Lõ ) r(   