/j$SSKJr SSKJr SSKJrJr SSKJrJ r SSK J r SSK J r "SS \5r"S S \5r\"S S 55r\"SS55r"SS5r"SS5r"SS5rg)) annotations) dataclass) AsyncIteratorOptional) FfiClient FfiHandle)ffi_pb2)data_track_pb2c"\rSrSrSrSSjrSrg)SubscribeDataTrackErrorz9An error that can occur when subscribing to a data track.cXlgNmessageselfrs G/app/agent/.venv/lib/python3.13/site-packages/livekit/rtc/data_track.py__init__ SubscribeDataTrackError.__init__ rNrstrreturnNone__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrr r s Crr c"\rSrSrSrSSjrSrg)PushFrameError zFrame 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 cXlgrrrs rrPushFrameError.__init__*rrrNrrr%rrr'r' s rr'c<\rSrSr%SrS\S'S\S'S\S'Srg ) DataTrackInfo.z)Information about a published data track.rsidnamebool uses_e2eer%N)rr r!r"r#__annotations__r$r%rrr,r,.s!3 H I6OLrr,c4\rSrSr%SrS\S'SrS\S'Srg) DataTrackFrame@zQA frame published on a data track, consisting of a payload and optional metadata.bytespayloadN Optional[int]user_timestampr%)rr r!r"r#r2r9r$r%rrr4r4@s[ N$(NM(;rr4c^\rSrSrSrS Sjr\S Sj5rS SjrSSjr SSjr SSjr S r g )LocalDataTrackKz.Data track published by the local participant.c[URRURRURRS9Ul[ URR5Ul gN)r.r/r1) r,infor.r/r1_infor handleid _ffi_handler owned_infos rrLocalDataTrack.__init__NsP"##%% oo//  %Z%6%6%9%9:rcUR$z!Information about the data track.r@rs rr?LocalDataTrack.infoVzzrc[R"[UR5S9nURbURUl[ R "5nURRURl URRRU5 [RRU5nURR!S5(a)[#URR$R&5eg)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. )r7Nerror)proto_data_trackr4r6r7r9 proto_ffi FfiRequestrCrAlocal_data_track_try_push track_handleframeCopyFromrinstancerequestHasFieldr'rNr)rrT proto_framereqresps rtry_pushLocalDataTrack.try_push[s'55eEMM>RS    +).)=)=K &""$595E5E5L5L%%2 %%++44[A!!))#.  ) ) 2 27 ; ; !?!?!E!E!M!MN N >>rc# [R"5nURRURl[ RRU5 g7f)zUnpublishes the track.N) rPrQrCrAlocal_data_track_unpublishrSrrVrWrrZs r unpublishLocalDataTrack.unpublishzsA""$6:6F6F6M6M&&3""3'sAAcdSURRSURRS3$)Nzrtc.LocalDataTrack(sid=, name=))r@r.r/rJs r__repr__LocalDataTrack.__repr__s*((8 ?PPQRRr)rCr@N)rEz$proto_data_track.OwnedLocalDataTrackrrrr,)rTr4rrrr0rrrr) rr r!r"r#rpropertyr?r\rargrlr$r%rrr;r;Ks48;O.?( Srr;cp\rSrSrSrS Sjr\S Sj5r\SSj5rSS.SSjjr SS jr SS jr S r g)RemoteDataTrackz-Data track published by a remote participant.c[URRURRURRS9Ul[ URR5Ul URUl gr>) r,r?r.r/r1r@r rArBrCpublisher_identity_publisher_identityrDs rrRemoteDataTrack.__init__s^"##%% oo//  %Z%6%6%9%9:#-#@#@ rcUR$rHrIrJs rr?RemoteDataTrack.inforLrcUR$)z4Identity of the participant who published the track.)rxrJs rrw"RemoteDataTrack.publisher_identitys'''rN) buffer_sizecx[R"5nUbXl[R"5nUR R URlURRRU5 [RRU5n[URR5$)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. )rODataTrackSubscribeOptionsr~rPrQrCrAsubscribe_data_trackrSoptionsrUrrVrWDataTrackStreamstream)rr~optsrZr[s r subscribeRemoteDataTrack.subscribes 99;  "* ""$040@0@0G0G  -   ((11$7!!))#.t88??@@rc[R"5nURRURl[ RRU5nURR$r_) rPrQrCrAremote_data_track_is_publishedrSrrVrWrarbs rraRemoteDataTrack.is_publishedsR""$:>:J:J:Q:Q**7!!))#.22???rc~SURRSURRSURS3$)Nzrtc.RemoteDataTrack(sid=rjz, publisher_identity=rk)r@r.r/rxrJs rrlRemoteDataTrack.__repr__s?&tzz~~&6gdjjoo=NO""&":":!;1 > r)rCr@rx)rEz%proto_data_track.OwnedRemoteDataTrackrrrnrq)r~r8rrro) rr r!r"r#rrrr?rwrrarlr$r%rrrtrtsI7A((9=A0@ rrtch\rSrSrSrS SjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr S r g )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^[URR5UlURRm[R R RU4SjS9UlSUl g)Ncl>URS5S:H=(a URRT:H$)Nrdata_track_stream_event) WhichOneofr stream_handle)e handle_ids r*DataTrackStream.__init__..s5 Y'+DDI--;;yHIr) filter_fnF) r rArBrCrrVqueuer_queue_closed)rrErs @rrDataTrackStream.__init__s^$Z%6%6%9%9:%%(( ((..889   rc`# UR5IShvN $N![a gf=f7f)z9Read a single frame, or ``None`` if the stream has ended.N) __anext__StopAsyncIterationrJs rreadDataTrackStream.reads. )) ))!  s(.. +.+.cU$rr%rJs r __aiter__DataTrackStream.__aiter__s rcd# UR(a[eUR5 URR 5IShvN nUR nUR S5nUS:XaNURRnSnURS5(a URn[URUS9$US:XaUUR5 URRS5(a[URR 5e[eUR5 [eN7f)Ndetailframe_receivedr9)r7r9eosrN)rr_send_read_requestrgetrrrrTrXr9r4r7_closerr rN)revent stream_eventrrYuser_tss rrDataTrackStream.__anext__s <<$ $ !*.++//*;$;44 ((2 % %&55;;K%)G##$455%44!#++& u_ KKM((11-l.>.>.D.DEE$ $ KKM$ $)%""$373C3C3J3J""0""3'rcUR(d;SUl[RRR UR 5 gg)NT)rrrVr unsubscriberrJs rrDataTrackStream._closes3||DL    $ $ 0 0 =rcXUR5 URR5 g)z2Explicitly close the subscription and unsubscribe.N)rrCdisposerJs rcloseDataTrackStream.close s    "rc,# UR5 g7fr)rrJs racloseDataTrackStream.acloses s)rrCrN)rEz%proto_data_track.OwnedDataTrackStreamrr)rzOptional[DataTrackFrame])rzAsyncIterator[DataTrackFrame])rr4rp)rr r!r"r#rrrrrrrrr$r%rrrrs/  %6( > # rrN) __future__r dataclassesrtypingrr _ffi_clientrr _protor rPr rO Exceptionr r'r,r4r;rtrr%rrrs#!*-(6i Y  MM M" << <6S6Sr: : zPPr