+ ~js ^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t H t H t H t H t HtHtHtHt^RIHtHt^RIHtHt^RIHt^RIHt^RIHt^R IHt ^R I!H"t"^R I#H$t$^R I%H&t&^R I'H(t(H)t)H*t*^RI+H,t,^RI-H.t.^RI/H0t0^RI1H2t2^RI-H3t3^RI4H5t5H6t6H7t7H8t8^RI9H:t:^RIH;t<!RR]=4t>!RR]=4t?!RR]=4t@!RR]=4tA!RR]=4tB!R R!]=4tC!R"R#]4tD] R$.] ] ]]E,,]]E,3,3,tF]!R%] ]3.] ] ]]E,,]]E,3,3,R&7tG!R'R(]D4tH!R)R*]D4tIR#)+) annotationsN) ListUnionCallableDict AwaitableOptionalMappingcastTypeVar)abstractmethodABC) FfiClient FfiHandle)ffi_pb2)participant_pb2)TrackPublishOptions)TranscriptionSegment)ParticipantTrackPermission)BroadcastQueue) LocalTrack)LocalTrackPublicationRemoteTrackPublicationTrackPublication) Transcription)RpcError)"RpcMethodInvocationResponseRequest)logger)RpcInvocationData)TextStreamWriterByteStreamWriterByteStreamInfoSTREAM_CHUNK_SIZE)LocalDataTrack)data_track_pb2c"]tRt^=tRRltRtR#)PublishTrackErrorc V^8dQhRRRR/#messagestrreturnNone)formats"l/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/rtc/participant.py __annotate__PublishTrackError.__annotate__>c WnR#Nr+selfr+s&&r1__init__PublishTrackError.__init__> r5r8N__name__ __module__ __qualname____firstlineno__r;__static_attributes__r/r5r1r'r'= r5r'c"]tRt^BtRRltRtR#)UnpublishTrackErrorc V^8dQhRRRR/#r)r/)r0s"r1r2 UnpublishTrackError.__annotate__Cr4r5c WnR#r7r8r9s&&r1r;UnpublishTrackError.__init__Cr=r5r8Nr>r/r5r1rFrFBrDr5rFc"]tRt^GtRRltRtR#)PublishDataErrorc V^8dQhRRRR/#r)r/)r0s"r1r2PublishDataError.__annotate__Hr4r5c WnR#r7r8r9s&&r1r;PublishDataError.__init__Hr=r5r8Nr>r/r5r1rLrLGrDr5rLc"]tRt^LtRRltRtR#)PublishDTMFErrorc V^8dQhRRRR/#r)r/)r0s"r1r2PublishDTMFError.__annotate__Mr4r5c WnR#r7r8r9s&&r1r;PublishDTMFError.__init__Mr=r5r8Nr>r/r5r1rRrRLrDr5rRc"]tRt^QtRRltRtR#)PublishTranscriptionErrorc V^8dQhRRRR/#r)r/)r0s"r1r2&PublishTranscriptionError.__annotate__Rr4r5c WnR#r7r8r9s&&r1r;"PublishTranscriptionError.__init__Rr=r5r8Nr>r/r5r1rXrXQrDr5rXc"]tRt^VtRRltRtR#)PublishDataTrackErrorc V^8dQhRRRR/#r)r/)r0s"r1r2"PublishDataTrackError.__annotate__Wr4r5c WnR#r7r8r9s&&r1r;PublishDataTrackError.__init__Wr=r5r8Nr>r/r5r1r^r^VrDr5r^c4]tRt^[tRRlt]]RRl44t]RRl4t]RRl4t ]R R l4t ]R R l4t ]R Rl4t ]RRl4t ]RRl4t]RRl4t]RRl4t]RRl4t]RRl4tRtR#) Participantc V^8dQhRRRR/#r* owned_info"proto_participant.OwnedParticipantr-r.r/)r0s"r1r2Participant.__annotate__\s;;#E;$;r5c pVPVn\VPP4VnR#r7)info_inforhandleid _ffi_handle)r:rgs&&r1r;Participant.__init__\s&__ $Z%6%6%9%9:r5cV^8dQhRR/#)r*r-zMapping[str, TrackPublication]r/)r0s"r1r2ribs  $B r5c R#)E A dictionary of track publications associated with the participant. Nr/r:s&r1track_publicationsParticipant.track_publications`s r5cV^8dQhRR/#r*r-r,r/)r0s"r1r2riisSr5c .VPP#r7)rlsidrts&r1rzParticipant.sidhszz~~r5cV^8dQhRR/#rxr/)r0s"r1r2rimscr5c .VPP#r7)rlnamerts&r1r~Participant.namelszzr5cV^8dQhRR/#rxr/)r0s"r1r2riq####r5c .VPP#r7)rlidentityrts&r1rParticipant.identitypzz"""r5cV^8dQhRR/#rxr/)r0s"r1r2riurr5c .VPP#r7)rlmetadatarts&r1rParticipant.metadatatrr5cV^8dQhRR/#)r*r-dict[str, str]r/)r0s"r1r2riys++N+r5c @\VPP4#)z2Custom attributes associated with the participant.)dictrl attributesrts&r1rParticipant.attributesxsDJJ))**r5cV^8dQhRR/#)r*r-z+proto_participant.ParticipantKind.ValueTyper/)r0s"r1r2ri~sAr5c .VPP#)zLParticipant's kind (e.g., regular participant, ingress, egress, sip, agent).)rlkindrts&r1rParticipant.kind}szzr5cV^8dQhRR/#)r*r-z7list[proto_participant.ParticipantKindDetail.ValueType]r/)r0s"r1r2ris--U-r5c @\VPP4#)zzAdditional details refining the participant's kind (e.g., cloud agent, forwarded, whatsapp/twilio connector, rtsp bridge).)listrl kind_detailsrts&r1rParticipant.kind_detailssDJJ++,,r5cV^8dQhRR/#)r*r-z,proto_participant.ParticipantState.ValueTyper/)r0s"r1r2ris  C r5c .VPP#)zGParticipant's connection state (joining, joined, active, disconnected).)rlstaterts&r1rParticipant.stateszzr5cV^8dQhRR/#)r*r-zdatetime.datetime | Noner/)r0s"r1r2ris  3 r5c VPP^8XdR#\PPVPPR, \PP R7#)zMTimestamp of when the participant joined the room, or None if not yet joined.N)tz)rl joined_atdatetime fromtimestamptimezoneutcrts&r1rParticipant.joined_atsW ::  1 $  .. JJ 4 'H,=,=,A,A/  r5cV^8dQhRR/#)r*r-z'proto_participant.ParticipantPermissionr/)r0s"r1r2ris%%D%r5c .VPP#)z.The participant's permissions within the room.)rl permissionrts&r1 permissionsParticipant.permissionsszz$$$r5cV^8dQhRR/#)r*r-z6Optional[proto_participant.DisconnectReason.ValueType]r/)r0s"r1r2ris,, ?,r5c VPP\PP8XdR#VPP#)aXReason for the participant's disconnection. Returns one of DisconnectReasons or None if the participant isn't disconnected. Common reasons are: - CLIENT_INITIATED - the client initiated the disconnect - DUPLICATE_IDENTITY - another participant with the same identity has joined the room - SERVER_SHUTDOWN - the server instance is shutting down - PARTICIPANT_REMOVED - RoomService.RemoveParticipant was called - ROOM_DELETED - RoomService.DeleteRoom was called - STATE_MISMATCH - the client is attempting to resume a session, but server is not aware of it - JOIN_FAILURE - client was unable to connect fully When dialing a participant via SIP, you may see the following reasons: - USER_UNAVAILABLE - SIP callee did not respond in time - USER_REJECTED - SIP callee rejected the call (busy) - SIP_TRUNK_FAILURE - SIP protocol failure or unexpected response N)rldisconnect_reasonproto_participantDisconnectReasonUNKNOWN_REASONrts&r1rParticipant.disconnect_reasons6( :: ' '+<+M+M+\+\ \zz+++r5)rorlN)r?r@rArBr;propertyr rurzr~rrrrrrrrrrCr/r5r1rdrd[s;  ####++--    %%,,r5rdrF)boundca]tRt^tRtRV3Rllt]RRl4tRRR.R R /R R lltR Rlt RRlt RR/RRllt R/LocalParticipant.publish_data..s !..11T5F5F5O5OOr5N) isinstancer,encodelenctypesc_byte proto_ffi FfiRequestrormrlocal_participant_handle addressofdata_ptrdata_lenrrrextendrinstancequeue subscriberequestwait_for unsubscribeerrorrL) r:rrrrrcdatareqrcbrs &&$$$ @r1rLocalParticipant.publish_datasr( gs # #nnW-Gw<)G4""$484D4D4K4K1$*$4$4U$;!$,!$,!!& //667MN""((224 8%%--c2D+0>>O,&B    $ $ 0 0 7 ?? "2??#8#89 9 ! &    $ $ 0 0 7s7D*H.7G%G&G*AH/!HG+G==Hc$V^8dQhRRRRRR/#)r*codeintdigitr,r-r.r/)r0s"r1r2rs!>>#>c>d>r5c a"\P!4pVPPVPnWPnW#Pn\PPP4p\PPV4oVPV3Rl4GRjxL p\PPPV4VPP'd \!VPP4hR#Lj \PPPT4i;i5i)z Publish SIP DTMF message. Args: code (int): DTMF code. digit (str): DTMF digit. Raises: PublishDTMFError: If there is an error in publishing SIP DTMF message. c^<VPPSPP8H#r7)publish_sip_dtmfrrs&r1r/LocalParticipant.publish_dtmf..s"!,,559N9N9W9WWr5N)rrrormrrrrrrrrrrrrrR)r:rrrrrrs&$$ @r1 publish_dtmfLocalParticipant.publish_dtmfs""$8<8H8H8O8O5$(!%*"""((224 8%%--c2D+0>>W,&B    $ $ 0 0 7   $ $ $"2#6#6#<#<= = % &    $ $ 0 0 7s7BE7D+>D)?D+AE!E)D+++EEc V^8dQhRRRR/#)r* transcriptionrr-r.r/)r0s"r1r2rs&L&L&L4&Lr5c a"\P!4pVPUu.uFPp\VPVP VP VPVPVPR7NKR ppVPPVPn VPVPnVPPPV4VP VPn\$P&P(P+4p\$P&P-V4oVP/V3Rl4GRjxL p\$P&P(P1V4VPP2'd \5VPP24hR#uupiLo \$P&P(P1T4i;i5i)z Publish transcription data to the room. Args: transcription (Transcription): The transcription data to publish. Raises: PublishTranscriptionError: If there is an error in publishing transcription. )rntext start_timeend_timefinallanguagec^<VPPSPP8H#r7)publish_transcriptionrrs&r1r8LocalParticipant.publish_transcription..7s"!11::d>X>X>a>aar5N)rrsegmentsProtoTranscriptionSegmentrnrrrrrrormrrparticipant_identityr track_sidtrack_idrrrrrrrrrX)r:rrsproto_segmentsrrrs&& @r1r&LocalParticipant.publish_transcriptions""$#++  , &44VV<<gg  ,   >B=M=M=T=T!!:9F9[9[!!6 !!**11.A-:-D-D!!*""((224 8%%--c2D+0>>a,&B    $ $ 0 0 7 # # ) ) )+B,D,D,J,JK K *5  (&    $ $ 0 0 7sC$G?AG =B*G?(7GG G$AG?)&G?G+G<<G?response_timeoutNc ,V^8dQhRRRRRRRRRR/#)r*destination_identityr,methodrr zOptional[float]r-r/)r0s"r1r2r?s>)&)&")& )&  )& * )& )&r5c ha"\P!4pVPPVPnWPnW%PnW5PnVe"\VR,4VPn \PPP4p\PPV4oVP!V3Rl4GRjxL p\PPP#V4VPP%R4'd+\&P(!VPP*4hVPP#L \PPP#T4i;i5i)a Initiate an RPC call to a remote participant. Args: destination_identity (str): The `identity` of the destination participant method (str): The method name to call payload (str): The method payload response_timeout (Optional[float]): Timeout for receiving a response after initial connection Returns: str: The response payload Raises: RpcError: On failure. Details in `message`. Nrc^<VPPSPP8H#r7) perform_rpcrrs&r1r.LocalParticipant.perform_rpc..as  0F0F$JZJZJcJc0cr5r)rrrormrrrrrrresponse_timeout_msrrrrrrrHasFieldr _from_protor) r:rrrr rrrrs &$$$$ @r1rLocalParticipant.perform_rpc?s+.""$373C3C3J3J0/C,!'")  '256F6M2NCOO /""((224 8%%--c2D~~&cddB    $ $ 0 0 7 >> " "7 + +&&r~~';';< <~~%%%e    $ $ 0 0 7s8B8F2<7F3F4F8A F2AF2F+F//F2c$V^8dQhRRRRRR/#)r* method_namer,handlerz Optional[F]r-zUnion[F, Callable[[F], F]]r/)r0s"r1r2rjs(4444 $ 4r5c 6aaRVV3RllpVe V!V4#V#)a Establishes the participant as a receiver for calls of the specified RPC method. Can be used either as a decorator or a regular method. The handler will receive one argument of type `RpcInvocationData` and should return a string response which will be forwarded back to the caller. The handler may be synchronous or asynchronous. If unable to respond within `response_timeout`, the caller will hang up and receive an error on their side. You may raise errors of type `RpcError` in the handler, and they will be forwarded to the caller. Other errors raised in your handler will be caught and forwarded to the caller as "1500 Application Error". Args: method_name (str): The name of the indicated RPC method. handler (Optional[Callable]): Handler to be invoked whenever an RPC request for this method is received. Omit this argument to use the decorator syntax. Returns: None (when used as a decorator it returns the decorator function) Example: # As a decorator: @room.local_participant.register_rpc_method("greet") async def greet_handler(data: RpcInvocationData) -> str: print(f"Received greeting from {data.caller_identity}: {data.payload}") return f"Hello, {data.caller_identity}!" # As a regular method: async def greet_handler(data: RpcInvocationData) -> str: print(f"Received greeting from {data.caller_identity}: {data.payload}") return f"Hello, {data.caller_identity}!" room.local_participant.register_rpc_method('greet', greet_handler) c V^8dQhRRRR/#)r* handler_funcrr-r/)r0s"r1r2:LocalParticipant.register_rpc_method..__annotate__s  1  r5c<VSPS&\P!4pSPPVP nSVP n\PPV4V#r7) rrrrormregister_rpc_methodrrrrr)rrrr:s& r1register6LocalParticipant.register_rpc_method..registersc.:D  { +&&(C?C?O?O?V?VC # # <-8C # # *    & &s + r5r/)r:rrr!sff& r1r $LocalParticipant.register_rpc_methodjs&R    G$ $Or5c V^8dQhRRRR/#)r*rr,r-r.r/)r0s"r1r2rs ( (C (D (r5c VPPVR4\P!4pVPP VP nWP n\PPV4R#)zs Unregisters a previously registered RPC method. Args: method (str): The name of the RPC method to unregister N) rpoprrrormunregister_rpc_methodrrrrr)r:rrs&& r1r'&LocalParticipant.unregister_rpc_methodsb vt,""$=A=M=M=T=T!!:+1!!(""3'r5participant_permissionsc$V^8dQhRRRRRR/#)r*allow_all_participantsrr)z*Optional[List[ParticipantTrackPermission]]r-r.r/)r0s"r1r2rs+((!%("L (  (r5c .Vf.p\P!4pVPPVPnWPnVPPPV4\PPV4R#)a\ Set the track subscription permissions for the local participant. Args: allow_all_participants (bool): Whether to allow all participants to subscribe to this participant's tracks. participant_permissions (List[ParticipantTrackPermission]): Participant-specific track subscription permissions, ignored if `allow_all_participants` is True. N) rrrorm"set_track_subscription_permissionsrall_participants_allowedrrrrr)r:r+r)rs&$$ r1r-3LocalParticipant.set_track_subscription_permissionsss # *&( #""$JNJZJZJaJa..GJ`..G ..::AABYZ""3'r5c4V^8dQhRRRRRRRRRRRR R R /#) r* invocation_idrrr, request_idcaller_identityrr floatr-r.r/)r0s"r1r2rsY5Q5Q5Q5Q 5Q  5Q  5Q 5Q 5Qr5c "RpRp\W4WV4p VPPV4p V 'g0\P!\P P 4pMg\P!V 4'd)\P!V !V 4VR7GRjxL pM"\\\ ,V !V 44p\*P,!\/VP0P2TV'dVP54MRVR7R7p \6P8P;V 4p V P<P>'d2V P<P>p\$P>!RV 24R#R#L \Pd0\P!\P P4h\Pd0\P!\P P4hi;i \dp T pRp ? EL\Rp ? i\"dM\$P&!RT R24\P!\P P(4pELi;i5i)N)timeoutz+Uncaught error returned by RPC handler for z'. Returning APPLICATION_ERROR instead. )rr1rr)rpc_method_invocation_responsez.error sending rpc method invocation response: ) rrgetr _built_in ErrorCodeUNSUPPORTED_METHODasyncioiscoroutinefunctionr TimeoutErrorRESPONSE_TIMEOUTCancelledErrorRECIPIENT_DISCONNECTEDr r r, Exceptionr exceptionAPPLICATION_ERRORrrrrorm _to_protorrrr7r)r:r1rr2r3rr response_errorresponse_payloadparamsrrrreserrs&&&&&&& r1_handle_rpc_method_invocation.LocalParticipant._handle_rpc_method_invocations.2*.":Z$$((0%//0B0B0U0UVN Z..w77\181A1A#FO5E2,((,HSM76?'K$""+M)-)9)9)@)@+4Bn..0( ,   ((-  - - 3 3 344::C LLI#O P 4;,#//V&001C1C1T1TUU"11\&001C1C1Z1Z[[\ '!& Z  A&J<<"*!3!3H4F4F4X4X!Y  ZsA#J&H!F $F %F )J*!H B J3J F AH"0HH J H("J( J5A J>JJJc V^8dQhRRRR/#)r*rr,r-r.r/)r0s"r1r2rs883848r5c a"\P!4pVPPVPnWPn\PPP4p\PPV4oVPV3Rl4GRjxL \PPPV4R#L/ \PPPT4i;i5i)z Set the metadata for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: metadata (str): The new metadata. c^<VPPSPP8H#r7)set_local_metadatarrs&r1r/LocalParticipant.set_metadata.. "!..774;R;R;[;[[r5N)rrrormrPrrrrrrrrr)r:rrrrs&& @r1 set_metadataLocalParticipant.set_metadatas""$:>:J:J:Q:Q7*2'""((224 8%%--c2D..[      $ $ 0 0 7      $ $ 0 0 70A3D77C .C/C 3+DC +D  Dc V^8dQhRRRR/#)r*r~r,r-r.r/)r0s"r1r2rs883848r5c a"\P!4pVPPVPnWPn\PPP4p\PPV4oVPV3Rl4GRjxL \PPPV4R#L/ \PPPT4i;i5i)z Set the name for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: name (str): The new name. c^<VPPSPP8H#r7)set_local_namerrs&r1r+LocalParticipant.set_name..#s"!**33t7J7J7S7SSr5N)rrrormrYrr~rrrrrrr)r:r~rrrs&& @r1set_nameLocalParticipant.set_names""$6:6F6F6M6M3"&""((224 8%%--c2D..S      $ $ 0 0 7      $ $ 0 0 7rUc V^8dQhRRRR/#)r*rrr-r.r/)r0s"r1r2r(s88~8$8r5c 0a"\P!4pVPPVPnVPP Uu/uFq3PVPbK ppVPV4VP4F5wrVVPP P4pWSnWcnK7 \PPP4p\PP!V4oVP#V3Rl4GRjxL \PPP%V4R#uupiL4 \PPP%T4i;i5i)z Set custom attributes for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: attributes (dict[str, str]): A dictionary of attributes to set. c^<VPPSPP8H#r7)set_local_attributesrrs&r1r1LocalParticipant.set_attributes..As"!0099T=V=V=_=__r5N)rrrormr`rrkeyvalueupdateitemsaddrrrrrrr) r:rrentryexisting_attributesrbrcrrs && @r1set_attributesLocalParticipant.set_attributes(s@""$<@ +D., D> 7D> 9 Ec V^8dQhRRRR/#)r*r~r,r-r$r/)r0s"r1r2rs $;$;$;  $;r5c Fa"\P!VR7p\P!4pVPP VP nVP PPV4\PPP4p\PPV4oVPV3Rl4GRjxL p\PPP!V4VP P#R4'd*\%VP P&P(4h\+VP P,4#L \PPP!T4i;i5i)alPublishes a data track. Args: name: The track name used to identify the track to other participants. Must not be empty and must be unique per publisher. Returns: The published data track. Use :meth:`LocalDataTrack.try_push` to send data frames on the track. Raises: PublishDataTrackError: If there is an error publishing the data track. )r~c^<VPPSPP8H#r7)publish_data_trackrrs&r1r5LocalParticipant.publish_data_track..rRr5Nr)proto_data_trackDataTrackOptionsrrrormrroptionsCopyFromrrrrrrrrr^rr+r$track)r:r~ proto_optsrrrrs&$ @r1r#LocalParticipant.publish_data_tracks.$&66DA ""$:>:J:J:Q:Q7 &&// ;""((224 8%%--c2D+0>>[,&B    $ $ 0 0 7 ) )' 2 2'(=(=(C(C(K(KL Lb3399::&    $ $ 0 0 7s8BF!#7E3E1E3A F!)AF!1E33+FF!c$V^8dQhRRRRRR/#)r*rrrrr-rr/)r0s"r1r2rs$'0'0'0*='0 '0r5c a"\P!4pVPPVPnVPPVPnVPPPV4VPP4p\PPV4oVPV3Rl4GRjxL pVPP'd \!VPP4h\#VPP$4pWnVP(VP*nW`P,VP(&VP/4VVPP1V4#L TPP1T4i;i5i)aC Publish a local track to the room. Args: track (LocalTrack): The track to publish. options (TrackPublishOptions, optional): Options for publishing the track. Returns: LocalTrackPublication: The publication of the published track. Raises: PublishTrackError: If there is an error in publishing the track. c^<VPPSPP8H#r7) publish_trackrrs&r1r0LocalParticipant.publish_track..s !//22d6H6H6Q6QQr5N)rrrormr track_handlerrrrrrrrrrr'r publication_trackrzrlr task_doner)r:rrrrrtrack_publicationrs&&& @r1rLocalParticipant.publish_tracksT ""$).):):)A)A&595E5E5L5L2 !!**73  **, 0%%--c2D+0>>Q,&B%%%'(8(8(>(>?? 5b6F6F6R6R S ', $/33EKKO>O $ $%6%:%: ; OO $    ( ( /&    ( ( /s7BG#7F!FF!;BF!GF!!F>>Gc V^8dQhRRRR/#)r*rr,r-r.r/)r0s"r1r2rs00s0t0r5c a"\P!4pVPPVPnWPnRVPnVPP4p\PPV4oVPV3Rl4GRjxL pVPP'd \VPP4hVP P#V4pRVnVP'4VPP)V4R#L TPP)T4i;i5i)z Unpublish a track from the room. Args: track_sid (str): The SID of the track to unpublish. Raises: UnpublishTrackError: If there is an error in unpublishing the track. Tc^<VPPSPP8H#r7)unpublish_trackrrs&r1r2LocalParticipant.unpublish_track..s"!++448L8L8U8UUr5N)rrrormrrrstop_on_unpublishrrrrrrrrFrr&rrr)r:rrrrrrs&& @r1r LocalParticipant.unpublish_tracks""$7;7G7G7N7N4(1%04-  **, 0%%--c2D+0>>U,&B!!''')"*<*<*B*BCC2266yAK!%K  OO     ( ( /&    ( ( /s7A6E":7E1E2EAE#E"EEE"cV^8dQhRR/#rxr/)r0s"r1r2r'scc#cr5c VRVP RVP RVP R2#)zrtc.LocalParticipant(sid= , identity=, name=)rzrr~rts&r1__repr__LocalParticipant.__repr__'s.*488*K gVZV_V_U``abbr5)rrrr7)r?r@rArB__doc__r;rrurrrrr r'r-rKrSr[rirwr~rrrrrrrrC __classcell__rs@r1rrs577(( ,: ,: -/ ,:  ,:\>8&LP)& -1 )&V4l ((OS (,5Qn8,8,8<7;  04  !% #'"&'+<7;    04 #'."&  4  04 !%7;<  7;  04 !%@$;NAT@U'0R0>ccr5rcPa]tRtRtRV3Rllt]RRl4tRRltRtV;t #) RemoteParticipanti+c V^8dQhRRRR/#rfr/)r0s"r1r2RemoteParticipant.__annotate__,sII#EI$Ir5c 4<\SV`V4/VnR#r7)rr;r)r:rgrs&&r1r;RemoteParticipant.__init__,s $FH r5cV^8dQhRR/#)r*r-z$Mapping[str, RemoteTrackPublication]r/)r0s"r1r2r1s(($H(r5c VP#rrrts&r1ru$RemoteParticipant.track_publications0rr5cV^8dQhRR/#rxr/)r0s"r1r2r7sdd#dr5c VRVP RVP RVP R2#)zrtc.RemoteParticipant(sid=rrrrrts&r1rRemoteParticipant.__repr__7s.+DHH:[wW[W`W`Vaabccr5r) r?r@rArBr;rrurrCrrs@r1rr+s/II(( ddr5r)J __future__rrr<rrrrtypingrrrrrr r r r abcr r _ffi_clientrr_protorrrr_proto.room_pb2rrr_proto.track_pb2r_utilsrrrrrrrrrrpcr_proto.rpc_pb2rlogrr data_streamr r!r"r# data_trackr$r%rrBr'rFrLrRrXr^rdr, RpcHandlerrrrr/r5r1rsM#  [[[#-(8# )>" '6  ) y y   I U,#U,p*+U9Xc]3KXVY]3Z-[[ \  x*+U9Xc]3KXVY]3Z-[[\ o c{o cd d dr5