+ ~j$^RIHt^RIHt^RIHtHt^RIHtH t ^RI H t ^RI H t!RR]4t!R R ]4t]!R R 44t]!R R44t!RR4t!RR4t!RR4tR#)) annotations) dataclass) AsyncIteratorOptional) FfiClient FfiHandle)ffi_pb2)data_track_pb2c&]tRt^tRtRRltRtR#)SubscribeDataTrackErrorz9An error that can occur when subscribing to a data track.c V^8dQhRRRR/#messagestrreturnNone)formats"k/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/rtc/data_track.py __annotate__$SubscribeDataTrackError.__annotate__c WnR#Nrselfrs&&r__init__ SubscribeDataTrackError.__init__ rrN__name__ __module__ __qualname____firstlineno____doc__r __static_attributes__rrrr r sCrr c&]tRt^ tRtRRltRtR#)PushFrameErrorzFrame could not be pushed to a data track. Pushing a frame can fail for several reasons: - The track has been unpublished by the local participant or SFU - The room is no longer connected - Frames are being pushed too fast c V^8dQhRRRR/#rr)rs"rrPushFrameError.__annotate__*rrc WnR#rrrs&&rr PushFrameError.__init__*r"rrNr#rrrr+r+ srr+c>]tRt^.t$RtR]R&R]R&R]R&RtR#) DataTrackInfoz)Information about a published data track.rsidnamebool uses_e2eerN)r$r%r&r'r(__annotations__r)rrrr1r1.s!3 H I6OLrr1c6]tRt^@t$RtR]R&RtR]R&RtR#)DataTrackFramezQA frame published on a data track, consisting of a payload and optional metadata.bytespayloadN Optional[int]user_timestampr)r$r%r&r'r(r6r<r)rrrr8r8@s[ N$(NM(;rr8cl]tRt^KtRtRRlt]RRl4tRRltRR lt R R lt R R lt Rt R#)LocalDataTrackz.Data track published by the local participant.c V^8dQhRRRR/#)r owned_infoz$proto_data_track.OwnedLocalDataTrackrrr)rs"rrLocalDataTrack.__annotate__Ns;;#G;D;rc \VPPVPPVPPR7Vn\ VPP4Vn R#)r2r3r5N) r1infor2r3r5_inforhandleid _ffi_handlerr@s&&rr LocalDataTrack.__init__NsP"##%% oo//  %Z%6%6%9%9:rcV^8dQhRR/#rrr1r)rs"rrrAWmrc VP#z!Information about the data track.rErs&rrDLocalDataTrack.infoVzzrc V^8dQhRRRR/#)rframer8rrr)rs"rrrA[sOOnOOrc (\P!\VP4R7pVPeVPVn\ P !4pVPPVPn VPPPV4\PPV4pVPP!R4'd*\#VPP$P&4hR#)zTry pushing a frame to subscribers of the track. See :class:`DataTrackFrame` for how to construct a frame and attach metadata. Args: frame: The data track frame to send. Raises: PushFrameError: If the push fails. )r:Nerror)proto_data_trackr8r9r:r< proto_ffi FfiRequestrHrFlocal_data_track_try_push track_handlerUCopyFromrinstancerequestHasFieldr+rWr)rrU proto_framereqresps&& rtry_pushLocalDataTrack.try_push[s'55eEMM>RS    +).)=)=K &""$595E5E5L5L%%2 %%++44[A!!))#.  ) ) 2 27 ; ; !?!?!E!E!M!MN N >>rcV^8dQhRR/#rrrr)rs"rrrAzs(((rc "\P!4pVPPVPn\ PPV4R#5i)zUnpublishes the track.N) rYrZrHrFlocal_data_track_unpublishr\rr^r_rrbs& r unpublishLocalDataTrack.unpublishzsA""$6:6F6F6M6M&&3""3'sAAcV^8dQhRR/#rrrr)rs"rrrAsSS#Src dRVPP RVPP R2#)zrtc.LocalDataTrack(sid=, name=))rEr2r3rQs&r__repr__LocalDataTrack.__repr__s*((8 ?PPQRRr)rHrEN) r$r%r&r'r(r propertyrDrdrkrsrzr)rrrr>r>Ks:8;O.?( SSrr>c~]tRt^tRtRRlt]RRl4t]RRl4tRR /R R llt R R lt RRlt Rt R #)RemoteDataTrackz-Data track published by a remote participant.c V^8dQhRRRR/#)rr@z%proto_data_track.OwnedRemoteDataTrackrrr)rs"rrRemoteDataTrack.__annotate__sAA#HATArc \VPPVPPVPPR7Vn\ VPP4Vn VPVn R#rC) r1rDr2r3r5rErrFrGrHpublisher_identity_publisher_identityrIs&&rr RemoteDataTrack.__init__s^"##%% oo//  %Z%6%6%9%9:#-#@#@ rcV^8dQhRR/#rLr)rs"rrrrMrc VP#rOrPrQs&rrDRemoteDataTrack.inforSrcV^8dQhRR/#rvr)rs"rrrs((C(rc VP#)z4Identity of the participant who published the track.)rrQs&rr"RemoteDataTrack.publisher_identitys'''r buffer_sizeNc V^8dQhRRRR/#)rrr;rDataTrackStreamr)rs"rrrsAA AArc z\P!4pVeWn\P!4pVP P VPnVPPPV4\PPV4p\VPP4#)aSubscribes to the data track to receive frames. Args: buffer_size: Maximum number of received frames to buffer internally. When ``None``, the default buffer size is used. Zero is not a valid buffer size; if a value of zero is provided, it will be clamped to one. Returns a :class:`DataTrackStream` that yields :class:`DataTrackFrame` instances as they arrive. If the subscription encounters an error, it is raised as :class:`SubscribeDataTrackError` when iteration ends. )rXDataTrackSubscribeOptionsrrYrZrHrFsubscribe_data_trackr\optionsr]rr^r_rstream)rroptsrbrcs&$ r subscribeRemoteDataTrack.subscribes 99;  "* ""$040@0@0G0G  -   ((11$7!!))#.t88??@@rcV^8dQhRR/#rgr)rs"rrrs@@d@rc \P!4pVPPVPn\ PPV4pVPP#ri) rYrZrHrFremote_data_track_is_publishedr\rr^r_rkrls& rrkRemoteDataTrack.is_publishedsR""$:>:J:J:Q:Q**7!!))#.22???rcV^8dQhRR/#rvr)rs"rrrs  # rc ~RVPP RVPP RVP R2#)zrtc.RemoteDataTrack(sid=rxz, publisher_identity=ry)rEr2r3rrQs&rrzRemoteDataTrack.__repr__s?&tzz~~&6gdjjoo=NO""&":":!;1 > r)rHrEr) r$r%r&r'r(r r|rDrrrkrzr)rrrr~r~sQ7A((AA0@  rr~cz]tRt^tRtRRltRRltRRltRR ltR R lt R R lt RRlt RRlt Rt R#)raAn active subscription to a remote data track. Use as an async iterator to receive frames:: stream = remote_track.subscribe() async for frame in stream: process(frame.payload) Dropping or closing the stream unsubscribes from the track. If subscribing to the track fails, :class:`SubscribeDataTrackError` is raised when iteration ends instead of a normal ``StopAsyncIteration``. c V^8dQhRRRR/#)rr@z%proto_data_track.OwnedDataTrackStreamrrr)rs"rrDataTrackStream.__annotate__s  #H T rc a\VPP4VnVPPo\P P PV3RlR7VnRVn R#)cn<VPR4R8H;'dVPPS8H#)rdata_track_stream_event) WhichOneofr stream_handle)e handle_ids&r*DataTrackStream.__init__..s; Y'+DDII--;;yHIr) filter_fnFN) rrFrGrHrr^queuer_queue_closed)rr@rs&&@rr DataTrackStream.__init__s^$Z%6%6%9%9:%%(( ((..889   rcV^8dQhRR/#)rrzOptional[DataTrackFrame]r)rs"rrrs4rc d"VP4GRjxL #L \dR#i;i5i)z9Read a single frame, or ``None`` if the stream has ended.N) __anext__StopAsyncIterationrQs&rreadDataTrackStream.reads. )) ))!  s(00 -0-0cV^8dQhRR/#)rrzAsyncIterator[DataTrackFrame]r)rs"rrrs8rc V#rrrQs&r __aiter__DataTrackStream.__aiter__s rcV^8dQhRR/#)rrr8r)rs"rrrs%%%rc "VP'd\hVP4VPP 4GRjxL pVP pVP R4pVR8XdSVPPpRpVPR4'd VPp\VPVR7#VR8XdaVP4VPPR4'd*\VPP P"4h\hVP4\hL5i)Ndetailframe_receivedr<)r:r<eosrW)rr_send_read_requestrgetrrrrUr`r<r8r:_closerr rWr)revent stream_eventrrauser_tss& rrDataTrackStream.__anext__s <<<$ $ !*.++//*;$;44 ((2 % %&55;;K%)G##$455%44!#++& u_ KKM((11-l.>.>.D.D.L.LMM$ $ KKM$ $)%""$373C3C3J3J""0""3'rcV^8dQhRR/#ror)rs"rrrs>>>rc VP'g=RVn\PPP VP 4R#R#)TN)rrr^r unsubscriberrQs&rrDataTrackStream._closes5|||DL    $ $ 0 0 =rcV^8dQhRR/#ror)rs"rrr s##t#rc ZVP4VPP4R#)z2Explicitly close the subscription and unsubscribe.N)rrHdisposerQs&rcloseDataTrackStream.close s    "rcV^8dQhRR/#ror)rs"rrrsdrc ."VP4R#5ir)rrQs&racloseDataTrackStream.acloses s)rrHrN)r$r%r&r'r(r rrrrrrrr)rrrrrs4  %6( > # rrN) __future__r dataclassesrtypingrr _ffi_clientrr_protor rYr rX Exceptionr r+r1r8r>r~rrrrrs#!*-(6i Y  MM M" << <6S6Sr: : zPPr