q hUhSSKJr SSKrSSKrSSKJrJr SSKJr SSKJ r SSK J r "SS 5rg) ) annotationsN) FfiHandle FfiClient)audio_frame_pb2)ffi_pb2) AudioFramec\rSrSrSrSSSjjr\SSj5r\SSj5r\SSj5r SSjr SS jr SS jr SS jr SS jrS rg) AudioSourceal Represents a real-time audio source with an internal audio queue. The `AudioSource` class allows you to push audio frames into a real-time audio source, managing an internal queue of audio data up to a maximum duration defined by `queue_size_ms`. It supports asynchronous operations to capture audio frames and to wait for the playback of all queued audio data. NcFXlX lU=(d [R"5Ul[ R "5n[RRURl XRl X%Rl X5Rl[R R#U5nURR$Ul[)UR&R*R,5UlSUlSUlSUlSUlg)a Initializes a new instance of the audio source. Args: sample_rate (int): The sample rate of the audio source in Hz. num_channels (int): The number of audio channels. queue_size_ms (int, optional): The buffer size of the audio queue in milliseconds. Defaults to 1000 ms. loop (asyncio.AbstractEventLoop, optional): The event loop to use. Defaults to `asyncio.get_event_loop()`. N) _sample_rate _num_channelsasyncioget_event_loop_loop proto_ffi FfiRequestproto_audio_frameAudioSourceTypeAUDIO_SOURCE_NATIVEnew_audio_sourcetype sample_rate num_channels queue_size_msrinstancerequestsource_inforhandleid _ffi_handle _last_capture_q_size _join_handle _join_fut)selfrrrloopreqresps J/var/www/html/env/lib/python3.13/site-packages/livekit/rtc/audio_source.py__init__AudioSource.__init__$s$()5W335 ""$$5$E$E$Y$Y!+6(,8)-:*!!))#.**11 $TZZ%6%6%9%9:  8<6:cUR$)z*The sample rate of the audio source in Hz.)rr)s r-rAudioSource.sample_rateIs   r0cUR$)zThe number of audio channels.)rr2s r-rAudioSource.num_channelsNs!!!r0ct[UR[R"5- UR-S5$)zDThe current duration (in seconds) of audio data queued for playback.r)maxr&time monotonicr%r2s r-queued_durationAudioSource.queued_durationSs,4<<$.."22T5G5GGMMr0c[R"5nURRURl[ RRU5nUR5 g)a Clears the internal audio queue, discarding all buffered audio data. This method immediately removes all audio data currently queued for playback, effectively resetting the audio source's buffer. Any audio frames that have been captured but not yet played will be discarded. This is useful in scenarios where you need to stop playback abruptly or prevent outdated audio data from being played. N) rrr$r"clear_audio_buffer source_handlerrr_release_waiter)r)r+_s r- clear_queueAudioSource.clear_queueXsN""$/3/?/?/F/F,    & &s + r0c.^# URS:XdURR(ag[R"5nUR S:XaSO X R - nU=R URUR- U- - slX lUR(aURR5 URcURR5Ul URRUR UR5Ul[R "5nURR"UR$lUR$R(R+UR-55 [.R0R2R5URS9n[.R0R7U5mUR9U4Sj5IShvN n[.R0R2R;U5 UR$R<(a[?UR$R<5egNh![.R0R2R;U5 f=f7f)a Captures an `AudioFrame` and queues it for playback. This method is used to push new audio data into the audio source. The audio data will be processed and queued. If the size of the audio frame exceeds the internal queue size, the method will wait until there is enough space in the queue to accommodate the frame. The method returns only when all of the data in the buffer has been pushed. Args: frame (AudioFrame): The audio frame to capture and queue. Raises: Exception: If there is an error during frame capture. rNr)r*c^>URRTRR:H$)N)capture_audio_frameasync_id)er,s r-+AudioSource.capture_frame..s"!//88DbufferCopyFrom _proto_inforrqueue subscriberwait_for unsubscribeerror Exception)r)framenowelapsedr+rRcbr,s @r- capture_frameAudioSource.capture_framefs"  $ $ )T-=-=-F-F nn++s2#>P>P8P 11D4D4DDwNN         $ $ & >> !!ZZ557DN JJ11$,,@T@TU""$040@0@0G0G- &&//0A0A0CD""((22 2C 8%%--c2D+0>>],&B    $ $ 0 0 7 ! ! ' 'B22889 9 ( &    $ $ 0 0 7s1GJ7I'<I%=I'A$J%I''+JJc|# URcg[R"UR5IShvN gN7f)z Waits for the audio source to finish playing out all audio data. This method ensures that all queued audio data has been played out before returning. It can be used to synchronize events after audio playback or to ensure that the audio queue is empty. N)r(rshieldr2s r-wait_for_playoutAudioSource.wait_for_playouts* >> ! nnT^^,,,s 2<:<cURcgURR5(dURRS5 SUlSUlSUlg)Nr)r(done set_resultr%r&r2s r-r?AudioSource._release_waitersJ >> ! ~~""$$ NN % %d +  r0c@# URR5 g7f)zZClose the audio source This method cleans up resources associated with the audio source. N)r$disposer2s r-acloseAudioSource.acloses   "s) r$r!r(r'r%rrr&r)iN) rintrrjrrjr*z asyncio.AbstractEventLoop | NonereturnNone)rkrj)rkfloat)rkrl)rXr rkrl)__name__ __module__ __qualname____firstlineno____doc__r.propertyrrr:rAr\r`r?rh__static_attributes__r0r-r r s"15 #;#;#; #; / #;  #;J!!""NN /:b - #r0r ) __future__rr8r _ffi_clientrr_protorrrr audio_framer r rur0r-rzs(# -8(#[#[#r0