/j3SSKJr SSKrSSKrSSKJr SSKJrJrJ r SSK J r J r SSK Jr SSK Jr SS KJr SS KJrJr SS KJr SS KJr SS KJr SSKJr SSKJ r \"SS55r!\"SS55r""SS5r#g)) annotationsN) dataclass)Any AsyncIteratorOptional) FfiClient FfiHandle)audio_frame_pb2)ffi_pb2) TrackSource) RingQueuetask_done_logger) AudioFrame)logger) Participant)Track)FrameProcessorc$\rSrSr%SrS\S'Srg)AudioFrameEvent"zmAn event representing a received audio frame. Attributes: frame (AudioFrame): The received audio frame. rframeN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rI/app/agent/.venv/lib/python3.13/site-packages/livekit/rtc/audio_stream.pyrr"s r!rc*\rSrSr%S\S'S\S'Srg)NoiseCancellationOptions-str module_idzdict[str, Any]optionsrN)rrrrrr rr!r"r$r$-s N r!r$c4\rSrSrSrSSSjjr\SSSSSSS.SS jj5r\SSSSSSS.SS jj5rSS jr SS jr SS jr Sr SSjr SSjrSSjrSSjrSrg) AudioStream3a?An asynchronous audio stream for receiving audio frames from a participant or track. The `AudioStream` class provides an asynchronous iterator over audio frames received from a specific track or participant. It allows you to receive audio frames in real-time with customizable sample rates and channel configurations. Nr逻rc <XlX@lXPlX`lU=(d [R "5Ul[RRRUR SS9Ul [U5Ul SUlSUlSUl[#U[$5(a#UR&UlUR(UlO[#U[*5(aXplUR R-UR/55UlUR0R3[45 Sn SU;aUR7USUSS9n OUR95n [;U R<R>5Ul U RBUl"g)aInitialize an `AudioStream` instance. Args: track (Optional[Track]): The audio track from which to receive audio. If not provided, you must specify `participant` and `track_source` in `kwargs`. loop (Optional[asyncio.AbstractEventLoop], optional): The event loop to use. Defaults to the current event loop. capacity (int, optional): The capacity of the internal frame queue. Defaults to 0 (unbounded). sample_rate (int, optional): The sample rate for the audio stream in Hz. Defaults to 48000. num_channels (int, optional): The number of audio channels. Defaults to 1. noise_cancellation (Optional[NoiseCancellationOptions | FrameProcessor[AudioFrame]], optional): If noise cancellation is used, pass a `NoiseCancellationOptions` or `FrameProcessor[AudioFrame]` instance created by the noise cancellation module. Example: ```python audio_stream = AudioStream( track=audio_track, sample_rate=44100, num_channels=2, ) audio_stream = AudioStream.from_track( track=audio_track, sample_rate=44100, num_channels=2, ) ``` c*URS5S:H$)Nmessageaudio_stream_event) WhichOneof)es r"&AudioStream.__init__..ms Y 7;O Or!) filter_fnN participant track_source)r6r7)#_track _sample_rate _num_channels_frame_size_msasyncioget_event_loop_loopr instancequeue subscribe _ffi_queuer_queue_audio_filter_module_audio_filter_options _processor isinstancer$r'r(r create_task_run_taskadd_done_callbackr%_create_owned_stream_from_participant_create_owned_streamr handleid _ffi_handleinfo_info) selftrackloopcapacity sample_rate num_channels frame_size_msnoise_cancellationkwargsstreams r"__init__AudioStream.__init__;sWR%* ')+5W335 $,,22<< JJO= :C89L 04!<@"=A (*B C C(:(D(DD %);)C)CD & *N ; ;0OZZ++DIIK8  $$%56 F "??"=1~@V@F..0F$V]]%5%56[[ r!)rUrVrWrXrYrZc $[UUUUSUUUUS9 $)aCreate an `AudioStream` from a participant's audio track. Args: participant (Participant): The participant from whom to receive audio. track_source (TrackSource.ValueType): The source of the audio track (e.g., microphone, screen share). loop (Optional[asyncio.AbstractEventLoop], optional): The event loop to use. Defaults to the current event loop. capacity (int, optional): The capacity of the internal frame queue. Defaults to 0 (unbounded). sample_rate (int, optional): The sample rate for the audio stream in Hz. Defaults to 48000. num_channels (int, optional): The number of audio channels. Defaults to 1. noise_cancellation (Optional[NoiseCancellationOptions], optional): If noise cancellation is used, pass a `NoiseCancellationOptions` instance created by the noise cancellation module. Returns: AudioStream: An instance of `AudioStream` that can be used to receive audio frames. Example: ```python audio_stream = AudioStream.from_participant( participant=participant, track_source=TrackSource.MICROPHONE, sample_rate=24000, num_channels=1, ) ``` N) r6r7rUrVrTrWrXrZrYr*) clsr6r7rUrVrWrXrYrZs r"from_participantAudioStream.from_participants-N#%#%1'  r!c  [UUUUUUUS9$)aCreate an `AudioStream` from an existing audio track. Args: track (Track): The audio track from which to receive audio. loop (Optional[asyncio.AbstractEventLoop], optional): The event loop to use. Defaults to the current event loop. capacity (int, optional): The capacity of the internal frame queue. Defaults to 0 (unbounded). sample_rate (int, optional): The sample rate for the audio stream in Hz. Defaults to 48000. num_channels (int, optional): The number of audio channels. Defaults to 1. noise_cancellation (Optional[NoiseCancellationOptions], optional): If noise cancellation is used, pass a `NoiseCancellationOptions` instance created by the noise cancellation module. Returns: AudioStream: An instance of `AudioStream` that can be used to receive audio frames. Example: ```python audio_stream = AudioStream.from_track( track=audio_track, sample_rate=44100, num_channels=2, ) ``` )rTrUrVrWrXrZrYr`)rarTrUrVrWrXrYrZs r" from_trackAudioStream.from_tracks'H#%1'  r!cj[RRRUR5 gN)r r?r@ unsubscriberBrSs r"__del__AudioStream.__del__s   ,,T__=r!cURce[R"5nURnURRR UlURUlURUl SUl UR(aURUl [RR UlUR$bUR$UlUR(b%[*R,"UR(5Ul[0R2R5U5nURR6$Nr)r8 proto_ffi FfiRequestnew_audio_streamrPrN track_handler9rWr:rXqueue_size_framesr;rYproto_audio_frameAudioStreamTypeAUDIO_STREAM_NATIVEtyperDaudio_filter_module_idrEjsondumpsaudio_filter_optionsr r?requestr\)rSreqrqresps r"rM AudioStream._create_owned_streams{{&&&""$//(, (?(?(F(F%'+'8'8$(,(:(:%-.*   -1-@-@  * 1 A A U U  $ $ 06:6O6O  3  % % 148JJt?Y?Y4Z  1!!))#.$$+++r!cd[R"5nURnURRUlUR UlURUl SUl [RRUlX$lUR (aUR UlUR$bUR$UlUR(b%[*R,"UR(5Ul[0R2R5U5nURR6$rn)rorpaudio_stream_from_participantrPrNparticipant_handler9rWr:rXrsrtrurvrwr7r;rYrDrxrEryrzr{r r?r|r\)rSr6r7r}rr~s r"rL1AudioStream._create_owned_stream_from_participants""$(+(I(I%;F;R;R;Y;Y%8484E4E%1595G5G%2:;%7->-N-N-b-b%*5A2   :>:M:M ) 7  $ $ 0CGC\C\ ) @  % % 1AE**B ) >!!))#.11888r!c# URRUR5IShvN nURnUR S5(aUR R n[R"U5nURb7URR(aURRU5n[U5nUR R#U5 O2UR S5(aUR R#S5 OGM[$R&R(R+UR5 gGN'![a [R"SSS9 Nf=f7f)NTframe_receivedz7Frame processing failed, passing through original frame)exc_infoeos)rBwait_for _is_eventr0HasFieldrrr_from_owned_inforFenabled_process ExceptionrwarningrrCputr r?r@ri)rSevent audio_eventowned_buffer_infors r"rIAudioStream._runs//224>>BBE>C>V>VK##$455$/$>$>$D$D!"334EF??.4??3J3J $ 8 8 ? (. &%%e,, %'*   ,,T__=)C%U%)s5*E;EA:E;(EBE;E85E;7E88E;cl# URR5 URIShvN gN7f)zAsynchronously close the audio stream. This method cleans up resources associated with the audio stream and waits for any pending operations to complete. N)rPdisposerJrjs r"acloseAudioStream.aclose,s&   "jjs *424c\URRURR:H$rh)r0 stream_handlerPrN)rSr2s r"rAudioStream._is_event5s%##11T5E5E5L5LLLr!cU$rhrrjs r" __aiter__AudioStream.__aiter__8s r!c# URR5(a[eURR 5IShvN nUc[eU$N7frh)rJdoneStopAsyncIterationrCget)rSitems r" __anext__AudioStream.__anext__;sD ::??  $ $[[__&& <$ $ 'sAAAA) rDrErPrBr;rRr>r:rFrCr9rJr8)Nrr,rNN)rTrrU#Optional[asyncio.AbstractEventLoop]rVintrWrrXrrY int | NonerZ?Optional[NoiseCancellationOptions | FrameProcessor[AudioFrame]]returnNone)r6rr7TrackSource.ValueTyperUrrVrrWrrXrrYrrZrrr*)rTrrUrrVrrWrrXrrYrrZrrr*)rr)rr)r6rr7rrr)r2zproto_ffi.FfiEventrbool)rzAsyncIterator[AudioFrameEvent])rr)rrrrrr] classmethodrbrerkrMrLrIrrrrr rr!r"r*r*3s59 $(^bJ!J!2J! J!  J!  J!"J!\J! J!X 59 $(^b0 !0 , 0 2 0  0 0 0 "0 \0  0 0 d 59 $(^b+ + 2 +  +  + + "+ \+  + + Z>,$9&96K9 9.>0Mr!r*)$ __future__rr<ry dataclassesrtypingrrr _ffi_clientr r _protor rtr ro_proto.track_pb2r _utilsrr audio_framerlogrr6rrTrframe_processorrrr$r*rr!r"rsu# !//-8()/#$+     PPr!