+ ~j3^RIHt^RIt^RIt^RIHt^RIHtHtH t ^RI H t H t ^RI Ht^RI Ht^RIHt^R IHtHt^R IHt^R IHt^R IHt^R IHt^RIH t ]!RR44t!]!RR44t"!RR4t#R#)) annotationsN) dataclass)Any AsyncIteratorOptional) FfiClient FfiHandle)audio_frame_pb2)ffi_pb2) TrackSource) RingQueuetask_done_logger) AudioFrame)logger) Participant)Track)FrameProcessorc&]tRt^"t$RtR]R&RtR#)AudioFrameEventzmAn event representing a received audio frame. Attributes: frame (AudioFrame): The received audio frame. rframeN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rm/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/rtc/audio_stream.pyrr"s rrc,]tRt^-t$R]R&R]R&RtR#)NoiseCancellationOptionsstr module_idzdict[str, Any]optionsrN)rrrrrrrrr r"r"-s N rr"c ]tRt^3tRtR RRllt]RRR^RRR ^R RR R/R R ll4t]RRR^RRR ^R RR R/RRll4tRRlt RRlt RRlt Rt RRlt RRltRRltRRltRtR#)! AudioStreama?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. N逻c8V^8dQhRRRRRRRRRRR R R R R R/#)trackrloop#Optional[asyncio.AbstractEventLoop]capacityint sample_rate num_channels frame_size_ms int | Nonenoise_cancellation?Optional[NoiseCancellationOptions | FrameProcessor[AudioFrame]]returnNoner)formats"r __annotate__AudioStream.__annotate__;seJ!J!J!2J! J!  J!  J!"J!\J! J!rc bWnW@nWPnW`nT;'g\P !4Vn\PPPVP RR7Vn \V4Vn RVnRVnRVn\#V\$4'd$VP&VnVP(VnM\#V\*4'dWpnVP P-VP/44VnVP0P3\44Rp RV9d#VP7VR,VR,R7p MVP94p \;V P<P>4Vn V PBVn"R#)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*VPR4R8H#)messageaudio_stream_event) WhichOneof)es&r &AudioStream.__init__..ms Y 7;O Or) filter_fnN participant track_source)rDrE)#_track _sample_rate _num_channels_frame_size_msasyncioget_event_loop_looprinstancequeue 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) selfr+r,r.r0r1r2r4kwargsstreams &&&&&&&&, r __init__AudioStream.__init__;sZR%* ')+55W335 $,,22<< JJO= :C89L 04!<@"=A (*B C C(:(D(DD %);)C)CD & *N ; ;0OZZ++DIIK8  $$%56 F "??"=1~@V@F..0F$V]]%5%56[[ rr,r.r0r1r2r4c<V^8dQhRRRRRRRRR RR RR R R RRR/ #)r*rDrrETrackSource.ValueTyper,r-r.r/r0r1r2r3r4r5r6r'r)r8s"r r9r:sg0 0 !0 , 0 2 0  0 0 0 "0 \0  0 rc  *\VVVVRVVVVR7 #)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) rDrEr,r.r+r0r1r4r2r') clsrDrEr,r.r0r1r2r4s &$$$$$$$$r from_participantAudioStream.from_participants-N#%#%1'  rc8V^8dQhRRRRRRRRRRR R R R R R/#)r*r+rr,r-r.r/r0r1r2r3r4r5r6r'r)r8s"r r9r:s]+ + + 2 +  +  + + "+ \+  + rc  &\VVVVVVVR7#)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, ) ``` )r+r,r.r0r1r4r2ri)rjr+r,r.r0r1r2r4s&$$$$$$$r from_trackAudioStream.from_tracks'H#%1'  rcV^8dQhRR/#r*r6r7r)r8s"r r9r:s>>>rc l\PPPVP4R#N)rrMrN unsubscriberPras&r __del__AudioStream.__del__s   ,,T__=rcV^8dQhRR/#)r*r6rr)r8s"r r9r:s,,c,rc VPfQh\P!4pVPpVPPP VnVPVnVPVn ^Vn VP'dVPVn \PP VnVP$eVP$VnVP(e&\*P,!VP(4Vn\0P2P5V4pVPP6#rt)rF proto_ffi FfiRequestnew_audio_streamr^r\ track_handlerGr0rHr1queue_size_framesrIr2proto_audio_frameAudioStreamTypeAUDIO_STREAM_NATIVEtyperRaudio_filter_module_idrSjsondumpsaudio_filter_optionsrrMrequestrc)rareqr}resps& r r[ AudioStream._create_owned_streams{{&&&""$//(, (?(?(F(F%'+'8'8$(,(:(:%-.*    -1-@-@  * 1 A A U U  $ $ 06:6O6O  3  % % 148JJt?Y?Y4Z  1!!))#.$$+++rc$V^8dQhRRRRRR/#)r*rDrrErgr6rr)r8s"r r9r:s$99&96K9 9rc j\P!4pVPpVPPVnVP VnVPVn ^Vn \PPVnW$nVP 'dVP VnVP$eVP$VnVP(e&\*P,!VP(4Vn\0P2P5V4pVPP6#)r)r{r|audio_stream_from_participantr^r\participant_handlerGr0rHr1rrrrrrErIr2rRrrSrrrrrMrrc)rarDrErrrs&&& r rZ1AudioStream._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 ) >!!))#.11888rc "VPPVP4GRjxL pVPpVP R4'dVP P p\P!V4pVPe9VPP'dVPPV4p\V4pVP P#V4KVP R4'gEKVP P#R4\$P&P(P+TP4R#EL- \d\P!RRR7Li;i5i)TNframe_receivedz7Frame processing failed, passing through original frame)exc_infoeos)rPwait_for _is_eventr>HasFieldrrr_from_owned_inforTenabled_process ExceptionrwarningrrQputrrMrNru)raevent audio_eventowned_buffer_infors& r rWAudioStream._runs//224>>BBE>C>V>VK##$455$/$>$>$D$D!"334EF??.4??3J3J3J $ 8 8 ? (. &%%e,, %  ,,T__=)C%U%)sA*FE&FAF+E stream_handler^r\)rar@s&&r rAudioStream._is_event5s%##11T5E5E5L5LLLrcV^8dQhRR/#)r*r6zAsyncIterator[AudioFrameEvent]r)r8s"r r9r:8s9rc V#rtrrvs&r __aiter__AudioStream.__aiter__8s rcV^8dQhRR/#)r*r6rr)r8s"r r9r:;src "VPP4'd\hVPP 4GRjxL pVf\hV#L5irt)rXdoneStopAsyncIterationrQget)raitems& r __anext__AudioStream.__anext__;sD ::??  $ $[[__&& <$ $ 'sAAAA) rRrSr^rPrIr`rLrHrTrQrGrXrF)Nrr(NN)rrrrrrd classmethodrkrorwr[rZrWrrrrrrrr r'r'3sJ!X0 59 0  0 !0 0 %)0 _c0 0 d+ 59 +  + ! + + %)+ _c+ + Z>,$9.>0Mrr')$ __future__rrJr dataclassesrtypingrrr _ffi_clientrr _protor rr r{_proto.track_pb2r _utilsr r audio_framerlogrrDrr+rframe_processorrrr"r'rrr rsu# !//-8()/#$+     PPr