+
    Bi@!                     N   ^ RI t ^ RIt^ RIHt ^ RIHtHtHtHtH	t	 ^ RI
HtHt . ROt ! R R]]P                  4      t]P                  P!                  R	]4      tR
 tR tR]/R ltR t ! R R4      t]! 4       t ! R R]4      t ! R R]4      t]P8                  ! ]]4       R# )    N)_crossinterp)ChannelErrorChannelNotFoundErrorChannelClosedErrorChannelEmptyErrorChannelNotEmptyError)UNBOUND_ERRORUNBOUND_REMOVESendChannelRecvChannelItemInterpreterDestroyedc                       ] tR t^tRtR# )r    N)__name__
__module____qualname____firstlineno____static_attributes__r       ,/usr/lib/python3.14/test/support/channels.pyr   r      s    r   queuec                 b    V \         J d   \        P                   p \        P                  ! V 4      # N)UNBOUNDr   serialize_unbound)unbounds   &r   _serialize_unboundr   "   s&    '&&))'22r   c                 p    \         P                  ! V \        4      pV\         P                  J d   \        pV# r   )r   resolve_unboundr   r   )flagresolveds   & r   _resolve_unboundr"   (   s-    ++D2JKH<'''Or   unbounditemsc                     \        V 4      pVw  p\        P                  ! VR4      p\        V4      \	        V4      rTVP                  W 4       WE3# )   )r   	_channelscreater   r   _set_unbound)r#   r   	unboundopcidrecvsends   $     r   r(   r(   /   sN     !.GJI


9b
)CS!;s#3$i.:r   c                      . p \         P                  ! 4        FT  w  rp\        V4      \        V4      3;pw  r5\	        VR 4      '       g   VP                  V4       V P                  V4       KV  	  V # )
_unboundop)r'   list_allr   r   hasattrr)   append)channelsr+   r*   _chanr-   s         r   r0   r0   @   sj    H&//1$S);s+;;;wqt\**i( 	 2 Or   c                   ~   a a ] tR t^Mt oRtV 3R ltR tR tR tR t	]
R 4       t]
R 4       t]
R	 4       tR
tVtV ;t# )_ChannelEndNc                  < \         SV `  V 4      pVP                  R 8X  d   \        P                  ! VRRR7      pM@VP                  R8X  d   \        P                  ! VRRR7      pM\        VP                  4      hWn        V# )r-   T)r-   forcer,   )r,   r9   )super__new___endr'   _channel_idNotImplementedError_id)clsr+   self	__class__s   && r   r;   _ChannelEnd.__new__R   sj    ws#99''$dCCYY& ''$dCC%dii00r   c                ^    \        V 4      P                   R \        V P                  4       R2# )z(id=))typer   intr?   rA   s   &r   __repr___ChannelEnd.__repr__]   s(    t*%%&d3txx=/;;r   c                ,    \        V P                  4      # r   )hashr?   rH   s   &r   __hash___ChannelEnd.__hash__`   s    DHH~r   c                    \        V \        4      '       d   \        V\        4      '       g   \        # M\        V\        4      '       g   \        # VP                  V P                  8H  # r   )
isinstancer   NotImplementedr   r?   )rA   others   &&r   __eq___ChannelEnd.__eq__c   sM    dK((e[11%% 2E;//!!yyDHH$$r   c                D    \        V 4      \        V P                  4      33# r   )rF   rG   r?   rH   s   &r   
__reduce___ChannelEnd.__reduce__l   s    T
S],--r   c                    V P                   # r   r?   rH   s   &r   id_ChannelEnd.ido   s    xxr   c                B    \         P                  ! V P                  4      # r   )r'   get_infor?   rH   s   &r   _info_ChannelEnd._infos   s    !!$((++r   c                .    V P                   P                  # r   )r^   closedrH   s   &r   	is_closed_ChannelEnd.is_closedw   s    zz   r   rY   )r   r   r   r   r<   r;   rI   rM   rS   rV   propertyrZ   r^   rb   r   __classdictcell____classcell__)rB   __classdict__s   @@r   r7   r7   M   sf      D	<%.   , , ! ! !r   r7   c                   V   a  ] tR t^t o RtR	R]! 4       RR
/R llt]3R ltR t	Rt
V tR# )r   r,   N	_sentinel_delayc                  Ve:   \        V4      pV^ 8  d   \        R4      h\        P                  ! 4       V,           p\        P                  ! V P
                  V4      w  rVWRJ d`   \        P                  ! V4       Ve!   \        P                  ! 4       X8  d   \        h\        P                  ! V P
                  V4      w  rVKd  Ve   \        V4      # V# )Nz"timeout value must be non-negative)	rG   
ValueErrortimer'   r,   r?   sleepTimeoutErrorr"   )rA   timeoutri   rj   endobjr*   s   &&$$   r   r,   RecvChannel.recv   s     'lG{ #EGG))+'C")<JJv"tyy{c'9""&^^DHHi@NC #I..
r   c                    V\         J d$   \        P                  ! V P                  4      w  r#M#\        P                  ! V P                  V4      w  r#Ve   \	        V4      # V# r   )_NOT_SETr'   r,   r?   r"   )rA   defaultrr   r*   s   &&  r   recv_nowaitRecvChannel.recv_nowait   sN     h&^^DHH5NC&^^DHHg>NC #I..
r   c                J    \         P                  ! V P                  R R7       R# )T)r,   Nr'   closer?   rH   s   &r   r{   RecvChannel.close       t,r   r   r   g{Gz?)r   r   r   r   r<   objectr,   ru   rw   r{   r   re   rg   s   @r   r   r      s7      Dx2 #+  - -r   c                      a  ] tR t^t o RtRR lt]R 4       t]R 4       tRRR/R llt	RR/R lt
RRR/R	 lltRR/R
 ltR tRtV tR# )r   r-   Nc                6    Vf   \        V4      pW3pW0n        V# r   )r"   _unbound)rA   opitemsr   s   &&& r   r)   SendChannel._set_unbound   s"    =$R(E+r   c                     V P                   w  rV#   \         d:    \        P                  ! T P                  4      w  r1T P                  T4      w  r T# i ; ir   )r   AttributeErrorr'   get_queue_defaultsr?   r)   )rA   r4   r   r   s   &   r   r#   SendChannel.unbounditems   sY    	-}}HA   	-00:EB((,HAu	-s    A AAc                Z    V P                   pVP                  ;'       g    VP                  # r   )r^   ra   closing)rA   infos   & r   rb   SendChannel.is_closed   s!    zz{{**dll*r   r#   c               v    Vf   RpM\        V4      w  p\        P                  ! V P                  WVRR7       R # NT)rp   blockingr&   r   r'   r-   r?   rA   rr   rp   r#   r*   s   &&&$ r   r-   SendChannel.send   s1     I+L9JItxx4Pr   c               p    Vf   RpM\        V4      w  p\        P                  ! V P                  WRR7      # NF)r   r&   r   rA   rr   r#   r*   s   &&$ r   send_nowaitSendChannel.send_nowait   s4     I+L9JI ~~dhhGGr   c               v    Vf   RpM\        V4      w  p\        P                  ! V P                  WVRR7       R # r   r   r'   send_bufferr?   r   s   &&&$ r   r   SendChannel.send_buffer   s6     I+L9JIdhh&-	>r   c               p    Vf   RpM\        V4      w  p\        P                  ! V P                  WRR7      # r   r   r   s   &&$ r   send_buffer_nowaitSendChannel.send_buffer_nowait  s4     I+L9JI$$TXXsNNr   c                J    \         P                  ! V P                  R R7       R# )T)r-   Nrz   rH   s   &r   r{   SendChannel.close  r}   r   )r   r   )r   r   r   r   r<   r)   rd   r#   rb   r-   r   r   r   r{   r   re   r   s   @r   r   r      s}      D   + +QQH!%H">!%>O(,O- -r   )r   r	   r
   r(   r0   r   r   r   r   r   r   )rm   _interpchannelsr'   concurrent.interpretersr   r   r   r   r   r   $concurrent.interpreters._crossinterpr	   r
   __all__r   UnboundItem	singletonr   r   r   r"   r(   r0   r7   r~   ru   r   r   _register_end_typesr   r   r   <module>r      s     # 0 
.|+DD.
 
"
"
,
,Wh
?37 "
,! ,!^ 8/-+ /-da-+ a-J 
  k; 7r   