
    +g                        S SK Jr  S SKJr  S SKrS SKrSSKJr  SSKJ	r	J
r
  \R                  " SS9 " S	 S
\
5      5       r\R                  " SS9 " S S\	5      5       rSS jrSS jrg)    )annotations)NoReturnN   )StapledStream)ReceiveStream
SendStreamF)slotsc                  b    \ rS rSr% \R
                  " \5      rS\S'   S	S jr	S
S jr
S
S jrSrg)RecordSendStream   zlist[str | tuple[str, object]]recordc                F   #    U R                   R                  SU45        g 7f)Nsend_allr   append)selfdatas     j/Users/Alptekin/Desktop/izin_takip/venv/lib/python3.13/site-packages/trio/_tests/test_highlevel_generic.pyr   RecordSendStream.send_all   s     J-.   !c                B   #    U R                   R                  S5        g 7f)Nwait_send_all_might_not_blockr   r   s    r   r   .RecordSendStream.wait_send_all_might_not_block   s     :;   c                B   #    U R                   R                  S5        g 7fNacloser   r   s    r   r   RecordSendStream.aclose        8$r    N)r   objectreturnNoner#   r$   )__name__
__module____qualname____firstlineno__attrsFactorylistr   __annotations__r   r   r   __static_attributes__r!       r   r   r      s%    -2]]4-@F*@/<%r/   r   c                  \    \ rS rSr% \R
                  " \5      rS\S'   SS	S jjr	S
S jr
Srg)RecordReceiveStream   z"list[str | tuple[str, int | None]]r   Nc                F   #    U R                   R                  SU45        g7f)Nreceive_somer/   r   )r   	max_bytess     r   r4    RecordReceiveStream.receive_some   s     NI67r   c                B   #    U R                   R                  S5        g 7fr   r   r   s    r   r   RecordReceiveStream.aclose"   r    r   r!   )N)r5   z
int | Noner#   bytesr%   )r&   r'   r(   r)   r*   r+   r,   r   r-   r4   r   r.   r!   r/   r   r1   r1      s     16t1DF.D%r/   r1   c                   ^#    [        5       m[        5       n [        TU 5      nUR                  TL d   eUR                  U L d   eUR                  S5      I S h  vN   UR                  5       I S h  vN   TR                  SS/:X  d   eTR                  R                  5         UR                  5       I S h  vN   TR                  S/:X  d   eTR                  R                  5         S	U4S jjnUTl	        UR                  5       I S h  vN   TR                  S/:X  d   eTR                  R                  5         U R                  / :X  d   eUR                  S5      I S h  vN   U R                  S/:X  d   eTR                  / :X  d   eU R                  R                  5         UR                  5       I S h  vN   U R                  S/:X  d   eTR                  S/:X  d   eg  GN GNx GN5 N N N87f)
N   foo)r   r;   r   r   c                 D   >#    T R                   R                  S5        g 7f)Nsend_eofr   )send_streams   r   fake_send_eof)test_StapledStream.<locals>.fake_send_eof:   s     !!*-s    r=     )r4   rA   r%   )r   r1   r   r>   receive_streamr   r   r   clearr=   r4   r   )rB   stapledr?   r>   s      @r   test_StapledStreamrE   &   s    "$K(*NK8G+---!!^333


6
"""

/
/
111'"    



(+++. )K



*---  B&&&


t
$$$  %;$<<<<###!
..
  XJ...(+++; #1   %
 sp   AG6G'G62G*3AG68G-9AG6G0AG6$G2%AG6;G4<,G6*G6-G60G62G64G6c                   #     " S S[         5      n  " S S[        5      n[        U " 5       U" 5       5      n[        R                  " [
        SS9 nUR                  5       I S h  vN   S S S 5        [        WR                  R                  [
        5      (       d   eUR                  R                  S/:X  d   eUR                  R                  S/:X  d   eg  Nr! , (       d  f       Nv= f7f)Nc                  ,   ^  \ rS rSrSU 4S jjrSrU =r$ )@test_StapledStream_with_erroring_close.<locals>.BrokenSendStreamQ   c                R   >#    [         TU ]  5       I S h  vN   [        S5      e N7f)Nz
send errorsuperr   
ValueErrorr   	__class__s    r   r   Gtest_StapledStream_with_erroring_close.<locals>.BrokenSendStream.acloseR   &     '."""\** #   '%'r!   r#   r   r&   r'   r(   r)   r   r.   __classcell__rO   s   @r   BrokenSendStreamrH   Q       	+ 	+r/   rW   c                  ,   ^  \ rS rSrSU 4S jjrSrU =r$ )Ctest_StapledStream_with_erroring_close.<locals>.BrokenReceiveStreamV   c                R   >#    [         TU ]  5       I S h  vN   [        S5      e N7f)Nz
recv errorrK   rN   s    r   r   Jtest_StapledStream_with_erroring_close.<locals>.BrokenReceiveStream.acloseW   rQ   rR   r!   rS   rT   rV   s   @r   BrokenReceiveStreamrZ   V   rX   r/   r^   z^(send|recv) error$)matchr   )r   r1   r   pytestraisesrM   r   
isinstancevalue__context__r>   r   rB   )rW   r^   rD   excinfos       r   &test_StapledStream_with_erroring_closerf   N   s     ++ +
+1 +
 ,.0C0EFG	z)?	@Gnn 
Agmm//<<<<%%(333!!((XJ666	 	 
A	@s1   AC*C$C%C)A.C*C
C'#C*r%   )
__future__r   typingr   r*   r`   _highlevel_genericr   abcr   r   definer   r1   rE   rf   r!   r/   r   <module>rl      sj    "    . + E
%z 
% 
% E%- % %%,P7r/   