Ë
    _§1hÜ  ã                  óÜ   — d dl mZ d dlmZ d dlZd dlZddlmZ ddlm	Z	m
Z
  ej                  d¬«       G d	„ d
e
«      «       Z ej                  d¬«       G d„ de	«      «       Zdd„Zdd„Zy)é    )Úannotations)ÚNoReturnNé   )ÚStapledStream)ÚReceiveStreamÚ
SendStreamF)Úslotsc                  óT   — e Zd ZU  ej                  e«      Zded<   dd„Zdd„Z	dd„Z
y)	ÚRecordSendStreamzlist[str | tuple[str, object]]Úrecordc              ƒ  óF   K  — | j                   j                  d|f«       y ­w)NÚsend_all©r   Úappend)ÚselfÚdatas     ú`/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/trio/_tests/test_highlevel_generic.pyr   zRecordSendStream.send_all   s   è ø€ Ø�‰×Ñ˜J¨Ð-Õ.ùó   ‚!c              ƒ  óB   K  — | j                   j                  d«       y ­w)NÚwait_send_all_might_not_blockr   ©r   s    r   r   z.RecordSendStream.wait_send_all_might_not_block   s   è ø€ Ø�‰×ÑÐ:Õ;ùó   ‚c              ƒ  óB   K  — | j                   j                  d«       y ­w©NÚacloser   r   s    r   r   zRecordSendStream.aclose   ó   è ø€ Ø�‰×Ñ˜8Õ$ùr   N)r   ÚobjectÚreturnÚNone©r   r   )Ú__name__Ú
__module__Ú__qualname__ÚattrsÚFactoryÚlistr   Ú__annotations__r   r   r   © ó    r   r   r      s'   … à-:¨U¯]©]¸4Ó-@€FÐ*Ó@ó/ó<ô%r)   r   c                  óN   — e Zd ZU  ej                  e«      Zded<   ddd„Zdd„Z	y)	ÚRecordReceiveStreamz"list[str | tuple[str, int | None]]r   Nc              ƒ  óF   K  — | j                   j                  d|f«       y­w)NÚreceive_somer)   r   )r   Ú	max_bytess     r   r-   z RecordReceiveStream.receive_some   s    è ø€ Ø�‰×Ñ˜N¨IÐ6Ô7Øùr   c              ƒ  óB   K  — | j                   j                  d«       y ­wr   r   r   s    r   r   zRecordReceiveStream.aclose"   r   r   )N)r.   z
int | Noner   Úbytesr    )
r!   r"   r#   r$   r%   r&   r   r'   r-   r   r(   r)   r   r+   r+      s"   … à1>°·±¸tÓ1D€FÐ.ÓDôô%r)   r+   c               ƒ  óØ  ‡K  — t        «       Št        «       } t        ‰| «      }|j                  ‰u sJ ‚|j                  | u sJ ‚|j                  d«      ƒ d {  –—†  |j                  «       ƒ d {  –—†  ‰j                  ddgk(  sJ ‚‰j                  j                  «        |j                  «       ƒ d {  –—†  ‰j                  dgk(  sJ ‚‰j                  j                  «        d	ˆfd„}|‰_	        |j                  «       ƒ d {  –—†  ‰j                  dgk(  sJ ‚‰j                  j                  «        | j                  g k(  sJ ‚|j                  d«      ƒ d {  –—†  | j                  dgk(  sJ ‚‰j                  g k(  sJ ‚| j                  j                  «        |j                  «       ƒ d {  –—†  | j                  dgk(  sJ ‚‰j                  dgk(  sJ ‚y 7 �Œƒ7 �Œn7 �Œ,7 ŒÝ7 Œ‰7 Œ6­w)
Nó   foo)r   r2   r   r   c               “  óD   •K  — ‰ j                   j                  d«       y ­w)NÚsend_eofr   )Úsend_streams   €r   Úfake_send_eofz)test_StapledStream.<locals>.fake_send_eof:   s   øè ø€ Ø×Ñ×!Ñ! *Õ-ùs   ƒ r4   éÒ  )r-   r7   r    )r   r+   r   r5   Úreceive_streamr   r   r   Úclearr4   r-   r   )r8   Ústapledr6   r5   s      @r   Útest_StapledStreamr;   &   sî  øè ø€ Ü"Ó$€KÜ(Ó*€NÜ˜K¨Ó8€Gà×Ñ +Ñ-Ð-Ð-Ø×!Ñ! ^Ñ3Ð3Ð3à
×
Ñ
˜6Ó
"×"Ð"Ø
×
/Ñ
/Ó
1×1Ð1Ø×ÑØØ'ð"ò ð ð ð ×Ñ×ÑÔà
×
Ñ
Ó
×ÐØ×Ñ ( Ò+Ð+Ð+Ø×Ñ×ÑÔõ.ð )€KÔØ
×
Ñ
Ó
×ÐØ×Ñ * Ò-Ð-Ð-à×Ñ×ÑÔØ× Ñ  BÒ&Ð&Ð&à
×
Ñ
˜tÓ
$×$Ð$Ø× Ñ Ð%;Ð$<Ò<Ð<Ð<Ø×Ñ Ò#Ð#Ð#Ø×Ñ×ÑÔ!à
�.‰.Ó
×ÐØ× Ñ  X JÒ.Ð.Ð.Ø×Ñ ( Ò+Ð+Ñ+ð; #ùØ1ùð ùð øð %øð
 úsp   ƒAG*ÁGÁG*Á0GÁ1AG*Â5G!Â6AG*ÄG$ÄAG*ÅG&ÅAG*Æ1G(Æ2*G*ÇG*Ç!G*Ç$G*Ç&G*Ç(G*c               ƒ  óÄ  K  —  G d„ dt         «      }  G d„ dt        «      }t         | «        |«       «      }t        j                  t
        d¬«      5 }|j                  «       ƒ d {  –—†  d d d «       t        j                  j                  t
        «      sJ ‚|j                  j                  dgk(  sJ ‚|j                  j                  dgk(  sJ ‚y 7 Œk# 1 sw Y   ŒjxY w­w)Nc                  ó    ‡ — e Zd Zdˆ fd„Zˆ xZS )ú@test_StapledStream_with_erroring_close.<locals>.BrokenSendStreamc              “  óR   •K  — t         ‰| �  «       ƒ d {  –—†  t        d«      ‚7 Œ­w)Nz
send error©Úsuperr   Ú
ValueError©r   Ú	__class__s    €r   r   zGtest_StapledStream_with_erroring_close.<locals>.BrokenSendStream.acloseR   ó'   øè ø€ Ü‘'‘.Ó"×"Ð"Ü˜\Ó*Ð*ð #úó   ƒ'•%–'©r   r   ©r!   r"   r#   r   Ú__classcell__©rD   s   @r   ÚBrokenSendStreamr>   Q   ó   ø„ ÷	+ñ 	+r)   rK   c                  ó    ‡ — e Zd Zdˆ fd„Zˆ xZS )úCtest_StapledStream_with_erroring_close.<locals>.BrokenReceiveStreamc              “  óR   •K  — t         ‰| �  «       ƒ d {  –—†  t        d«      ‚7 Œ­w)Nz
recv errorr@   rC   s    €r   r   zJtest_StapledStream_with_erroring_close.<locals>.BrokenReceiveStream.acloseW   rE   rF   rG   rH   rJ   s   @r   ÚBrokenReceiveStreamrN   V   rL   r)   rP   z^(send|recv) error$)Úmatchr   )r   r+   r   ÚpytestÚraisesrB   r   Ú
isinstanceÚvalueÚ__context__r5   r   r8   )rK   rP   r:   Úexcinfos       r   Ú&test_StapledStream_with_erroring_closerX   N   sÃ   è ø€ ô+Ô+ô +ô
+Ô1ô +ô
 Ñ,Ó.Ñ0CÓ0EÓF€Gä	�‰”zÐ)?Ô	@ð ÀGØ�n‰nÓ×Ð÷ä�g—m‘m×/Ñ/´Ô<Ð<Ð<à×Ñ×%Ñ%¨(¨Ò3Ð3Ð3Ø×!Ñ!×(Ñ(¨X¨JÒ6Ð6Ñ6ð	 	ø÷ð üs1   ‚AC ÁCÁ&CÁ'CÁ+A'C ÃCÃCÃC r    )Ú
__future__r   Útypingr   r$   rR   Ú_highlevel_genericr   Úabcr   r   Údefiner   r+   r;   rX   r(   r)   r   ú<module>r^      sn   ðÝ "å ã Û å .ß +ð €‡��EÔô
%�zó 
%ó ð
%ð €‡��EÔô%˜-ó %ó ð%ó%,ôP7r)   