q hSSKrSSKrSSKrSSKJr SSKJrJr SSK J r SSK J r \\ r \"SS55r"S S 5rg) N) dataclass) AsyncIteratorOptional) AudioFrame)loggercp\rSrSr%\\S'\R\S'\R\S'\\S'\\S'Sr g) _Contribution streamdatabufferhad_data exhaustedN) __name__ __module__ __qualname____firstlineno___Stream__annotations__npndarraybool__static_attributes__rI/var/www/html/env/lib/python3.13/site-packages/livekit/rtc/audio_mixer.pyr r s% O ** JJNOrr c \rSrSrSSSS.S\S\S\S\S \S S 4 S jjrS \\S S 4SjrS \\S S 4Sjr SSjr S \4Sjr SSjr SSjr SSjrS \\S\R S \4SjrSrg ) AudioMixerrd) blocksizestream_timeout_mscapacity sample_rate num_channelsr"r#r$returnNc[5Ul0UlXlX lUS:aUO [ US-5UlX@l[R"US9Ul SUl [R"UR55Ulg)au Initialize the AudioMixer. The mixer accepts multiple async audio streams and mixes them into a single output stream. Each output frame is generated with a fixed chunk size determined by the blocksize (in samples). If blocksize is not provided (or 0), it defaults to 100ms. Each input stream is processed in parallel, accumulating audio data until at least one chunk of samples is available. If an input stream does not provide data within the specified timeout, a warning is logged. The mixer can be closed immediately (dropping unconsumed frames) or allowed to flush remaining data using end_input(). Args: sample_rate (int): The audio sample rate in Hz. num_channels (int): The number of audio channels. blocksize (int, optional): The size of the audio block (in samples) for mixing. If not provided, defaults to sample_rate // 10. stream_timeout_ms (int, optional): The maximum wait time in milliseconds for each stream to provide audio data before timing out. Defaults to 100 ms. capacity (int, optional): The maximum number of mixed frames to store in the output queue. Defaults to 100. r )maxsizeFN)set_streams_buffers _sample_rate _num_channelsint _chunk_size_stream_timeout_msasyncioQueue_queue_ending create_task_mixer _mixer_task)selfr%r&r"r#r$s r__init__AudioMixer.__init__st>'*e 35 !,".-6] KSUDU@V'8;B==QY;Z # )0)<)5n UR@RCU 5IShvN GMUR@RCS5IShvN gGNs snfGNNN8N7f) NTg{Gz?rr>return_exceptionsFgMbP?axisii)"r6r,r3sleeplist_get_contributionr-rRrrBr/rCgather isinstancer appendr astypefloat32rr rrshaperJsumstackcliprtobytesr.r1r5put) r:r tasksresults contributionsany_dataremovalscontribmixedframes rr8AudioMixer._mixer{sJ||DMM==mmD)))#4==1  2F &&MM%%fbhh4;M;M7NVXV^V^._`2 $NNEJTJJGMHH"!'=99$$W\\%8%8%DE07 gnn-###H$$$)=)=a)@A)EOOGNN3##""6*#mmE***FF288M:CEGGE65188BE !2!2D4F4FHXHXE++//%( ( (WZkkood###O*K&+ )#svALK7L0A#K:L.K?/B#LL5ALLBrc)rmr1r3wait_forrUr2 TimeoutErrorrwarningrSr frombufferr rqrCreshaper/size concatenatezerosrBr ) r:r r|rrrznew_datarxpads rrgAudioMixer._get_contributions99QAXX"..#q98CHiilT---ii 99Q<4++ +1!1!12C8H8H8J4KS((D,,syy|;T=O=OPXZX`X`aCz2!T//0AVcYGG-'' !4VHrsK!*#  #  sHsHr