F\h^PSrSSKrSSKrSSKJr SSKJrJrJrJ r J r SSKJ r J r /SQr "SS \\R5r\RR!S \5rS rS r\S .SjrSr"SS5r\"5r"SS\5r"SS\5r\R8"\\5 g)z-Cross-interpreter Channels High Level Module.N) _crossinterp) ChannelErrorChannelNotFoundErrorChannelClosedErrorChannelEmptyErrorChannelNotEmptyError) UNBOUND_ERRORUNBOUND_REMOVE) UNBOUNDr r createlist_all SendChannel RecvChannelrrrItemInterpreterDestroyedc\rSrSrSrSrg)rz#Raised from get() and get_nowait().N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r9/usr/lib/python3.13/test/support/interpreters/channels.pyrrs-rrqueuec`U[La[Rn[R"U5$N)r rserialize_unboundunbounds r_serialize_unboundr#"s&'&&  ) )' 22rcn[R"U[5nU[RLa[nU$r)rresolve_unboundrr )flagresolveds r_resolve_unboundr((s-++D2JKH<''' Or) unbounditemscx[U5nUun[R"U5n[U5[ X1S9pTXE4$)a9Return (recv, send) for a new cross-interpreter channel. The channel may be used to pass data safely between interpreters. "unbounditems" sets the default for the send end of the channel. See SendChannel.send() for supported values. The default value is UNBOUND, which replaces the unbound item when received. _unbound)r# _channelsr rr)r)r" unboundopcidrecvsends rr r /s>!.GJI   9 %CS!;s#E$ :rc [R"5VVs/sHup[U5[XS94PM snn$s snnf)z4Return a list of (recv, send) for all open channels.r+)r-rrr)r/r"s rrr?sC!* 2 2 4 6 4  {3A B 4 66 6s =c~^\rSrSrSrSrU4SjrSrSrSr Sr S r \ S 5r \ S 5r\ S 5rS rU=r$) _ChannelEndEz/The base class for RecvChannel and SendChannel.Nc>[TU]U5nURS:Xa[R"USSS9nONC  ; )S );#I. . rcB[R"URSS9 g)NT)r0r-closer=rFs rr}RecvChannel.closet,rrr) rrrrrr:objectr0rwryr}rrrrrr{s+; Dx2#+ -rrc^\rSrSrSrSrSS.U4Sjjr\S5rSSS.S jjr SS.S jr SSS.S jjr SS.S jr S r SrU=r$)rz/The sending end of a cross-interpreter channel.r1Nr+c>Uc[R"U5nU4n[ TU]X5nX$lU$![a [[5nN2f=fr)r-get_channel_defaultsrr#r r8r9r,)r>r/r,opr?r@s rr9SendChannel.__new__sZ   733C85ws(  ( 7-g6 7s6AAcXURnUR=(d UR$r)r_rbclosing)r?infos rrcSendChannel.is_closedszz{{*dll*rr!cUcURunO [U5un[R"URXUSS9 g)zkSend the object (i.e. its data) to the channel's receiving end. This blocks until the object is received. NTrrblockingr,r#r-r1r=r?rtrrr"r.s rr1SendChannel.sends6 ?JI+G4JItxx4PrcUcURunO [U5un[R"URXSS9$)zSend the object to the channel's receiving end. If the object is immediately received then return True (else False). Otherwise this is the same as send(). Frrr?rtr"r.s r send_nowaitSendChannel.send_nowaits9 ?JI+G4JI~~dhhGGrcUcURunO [U5un[R"URXUSS9 g)zdSend the object's buffer to the channel's receiving end. This blocks until the object is received. NTrr,r#r- send_bufferr=rs rrSendChannel.send_buffers; ?JI+G4JIdhh&- >rcUcURunO [U5un[R"URXSS9$)zSend the object's buffer to the channel's receiving end. If the object is immediately received then return True (else False). Otherwise this is the same as send(). Frrrs rsend_buffer_nowaitSendChannel.send_buffer_nowaits9 ?JI+G4JI$$TXXsNNrcB[R"URSS9 g)NT)r1r|rFs rr}SendChannel.closerrr)rrrrrr:r9rercr1rrrr}rrfrgs@rrrsh9 D&*  ++ Q Q!H" >  >$( O--rr)rrn_interpchannelsr-rrrrrr r r __all__r UnboundItem singletonrr r#r(r rr4rrwrr_register_end_typesrrrrs3 #  .|+DD.  " " , ,Wh ?3 #  6 0!0!f 8/-+/-dP-+P-h k;7r