h^. SSKrSSKJrJrJr SSKrSSKJr SSKJrJ r SSK J r J r "SS5rS\R 4S jr"S S 5rS \S \S\S\S\\S\\ 4 SjrS\R 4Sjr"SS5rg)N)IteratorListOptional)Tensor)_get_afilter_descStreamingMediaDecoder) CodecConfigStreamingMediaEncoderc2\rSrSrSrSrS\4SjrSrSr g) _StreamingIOBuffer z6Streaming Bytes IO buffer. Data are dropped when read.c/UlgN_buffer)selfs O/var/www/auris/envauris/lib/python3.13/site-packages/torchaudio/io/_effector.py__init___StreamingIOBuffer.__init__s $& bc\U(aURRU5 [U5$r)rappendlen)rrs rwrite_StreamingIOBuffer.writes LL   "1v rcUR(dg[URS5U::aURRS5$URSSUnURSUSURS'U$)zMPop the oldest byte string. It does not necessary return the requested amountrrN)rrpop)rnrets rr_StreamingIOBuffer.popsk|| t||A 1 $<<##A& &ll1obq!,,q/!"- Q rrN) __name__ __module__ __qualname____firstlineno____doc__rbytesrr__static_attributes__rrr r s@'u rr dtypec [RS[RS[RS[RS[R S0nX;a[ SUSUR535eX$)Nu8s16s32fltdblUnsupported dtype is provided . Supported dtypes are: torchuint8int16int32float32float64 ValueErrorkeysr*typess r_get_sample_fmtr>!sk T U U u u  E 9%@XY^YcYcYeXfghh <rcP\rSrSrSrS\S\S\S\S\\S\\ S \4S jr S r S r g )_AudioStreamingEncoder.z3Given a waveform, encode on-demand and return bytessrc sample_rateeffectmuxerencoder codec_configframes_per_chunkc .Xl[5Ul[URUS9UlURR UR S5U[UR5UUUS9 URR5 Xpl SUl gN)format) num_channelsrCrKrF filter_descrGr) rBr buffer StreamWriterwriteradd_audio_streamsizer>r*openfpci_iter)rrBrCrDrErFrGrHs rr_AudioStreamingEncoder.__init__1s(* "4;;u=  $$!#"399-% %  #  rcURR(Gd URS:aURR SUR URURUR -5 U=RUR - slURUR RS5:a;URR5 URR5 SUlURR(dURS:aMURRU5$)Nr) rOrrVrQwrite_audio_chunkrBrUrSflushcloser)rrs rread_AudioStreamingEncoder.readNs++%%%$++*: KK ) )!TXXdkkDKKRVRZRZDZ-[ \ KK488 #K{{dhhmmA.. !!# !!#  ++%%$++*:{{q!!r)rOrUrVrBrQN) r"r#r$r%r&rintstrrr rr]r(r)rrr@r@.s\=     # {+:"rr@rBrCrDrErFrGc H[R"5n[XcS9nURUR S5U[ UR 5UUUS9 UR5 URSU5 SSS5 URS5 U$!,(df  N!=frJ) ioBytesIOrPrRrSr>r*rTrZseek)rBrCrDrErFrGrOrQs r_encodereYsZZ\F & /F XXa[syy)!    C(  KKN M s %B B!c [RS[RS[RS[RS[R S0nX;a[ SUSUR535eX$)Nr,s16les32lef32lef64ler1r2r3r<s r _get_muxerrkqsm  T W W w w  E 9%@XY^YcYcYeXfghh <rc \rSrSrSrSSSSS.S\\S\\S\\S \\S \4 S jjjr SS jr SS \ S\ S\\ S\ 4Sjjr SS \ S\ S\ S\\ S\\ 4 SjjrSrg) AudioEffectora Apply various filters and/or codecs to waveforms. .. versionadded:: 2.1 Args: effect (str or None, optional): Filter expressions or ``None`` to apply no filter. See https://ffmpeg.org/ffmpeg-filters.html#Audio-Filters for the details of filter syntax. format (str or None, optional): When provided, encode the audio into the corresponding format. Default: ``None``. encoder (str or None, optional): When provided, override the encoder used by the ``format``. Default: ``None``. codec_config (CodecConfig or None, optional): When provided, configure the encoding codec. Should be provided in conjunction with ``format`` option. pad_end (bool, optional): When enabled, and if the waveform becomes shorter after applying effects/codec, then pad the end with silence. Example - Basic usage To use ``AudioEffector``, first instantiate it with a set of ``effect`` and ``format``. >>> # instantiate the effector >>> effector = AudioEffector(effect=..., format=...) Then, use :py:meth:`~AudioEffector.apply` or :py:meth:`~AudioEffector.stream` method to apply them. >>> # Apply the effect to the whole waveform >>> applied = effector.apply(waveform, sample_rate) >>> # Apply the effect chunk-by-chunk >>> for chunk in effector.stream(waveform, sample_rate): >>> ... Example - Applying effects Please refer to https://ffmpeg.org/ffmpeg-filters.html#Filtergraph-description for the overview of filter description, and https://ffmpeg.org/ffmpeg-filters.html#toc-Audio-Filters for the list of available filters. Tempo - https://ffmpeg.org/ffmpeg-filters.html#atempo >>> AudioEffector(effect="atempo=1.5") Echo - https://ffmpeg.org/ffmpeg-filters.html#aecho >>> AudioEffector(effect="aecho=0.8:0.88:60:0.4") Flanger - https://ffmpeg.org/ffmpeg-filters.html#flanger >>> AudioEffector(effect="aflanger") Vibrato - https://ffmpeg.org/ffmpeg-filters.html#vibrato >>> AudioEffector(effect="vibrato") Tremolo - https://ffmpeg.org/ffmpeg-filters.html#tremolo >>> AudioEffector(effect="vibrato") You can also apply multiple effects at once. >>> AudioEffector(effect="") Example - Applying codec One can apply codec using ``format`` argument. ``format`` can be audio format or container format. If the container format supports multiple encoders, you can specify it with ``encoder`` argument. Wav format (no compression is applied but samples are converted to 16-bit signed integer) >>> AudioEffector(format="wav") Ogg format with default encoder >>> AudioEffector(format="ogg") Ogg format with vorbis >>> AudioEffector(format="ogg", encoder="vorbis") Ogg format with opus >>> AudioEffector(format="ogg", encoder="opus") Webm format with opus >>> AudioEffector(format="webm", encoder="opus") Example - Applying codec with configuration Reference: https://trac.ffmpeg.org/wiki/Encode/MP3 MP3 with default config >>> AudioEffector(format="mp3") MP3 with variable bitrate >>> AudioEffector(format="mp3", codec_config=CodecConfig(qscale=5)) MP3 with constant bitrate >>> AudioEffector(format="mp3", codec_config=CodecConfig(bit_rate=32_000)) NT)rFrGpad_endrDrKrFrGrochUcUcUb [S5eXlX lX0lX@lXPlg)NzM`encoder` and/or `condec_config` opions are provided without `format` option.)r:rDrKrFrGro)rrDrKrFrGros rrAudioEffector.__init__s: >"l&> !pqq   ( rc 4URupVURb2URnURn0n URS:XaUUS.n O[UR5nSnUUS.n Uc#[ XUR XxUR5n O#[XUR XxURU5n UcUOUn [U [UR5U5n UR(aU SU3n [XU S9n U RU=(d SSU S9 U $)Nmulaw)rCchannelsz,apad=whole_len=)rKoptionrY)rN)shaperKrFrkr*rerDrGr@rr>ro StreamReaderrR)rwaveformrCoutput_sample_raterH num_framesrMrErFrurB output_srrNreaders r _get_readerAudioEffector._get_readers#+>> ;; "KKEllGF{{g%,7=,Yx~~.EG(3}l^UF  #(edN_N_`C(t{{EDDUDUWgC$6#=KCU ' ?8>>3RT`a <<(M)9*FKc? 0 6B T rrxrCryreturncURS:wa[SUR35eUR5S:XaU$URXU5nUR 5 UR 5un[ U5$)aLApply the effect and/or codecs to the whole tensor. Args: waveform (Tensor): The input waveform. Shape: ``(time, channel)`` sample_rate (int): Sample rate of the input waveform. output_sample_rate (int or None, optional): Output sample rate. If provided, override the output sample rate. Otherwise, the resulting tensor is resampled to have the same sample rate as the input. Default: ``None``. Returns: Tensor: Resulting Tensor. Shape: ``(time, channel)``. The number of frames could be different from that of the input. -Expected the input waveform to be 2D. Found: r)ndimr:numelr}process_all_packets pop_chunksr)rrxrCryr|applieds rapplyAudioEffector.apply"st" ==A LX]]O\] ] >> q O!!(9KL""$&&( grrHc## URS:wa[SUR35eUR5S:XaU$URXXC5nUR 5Hun[ U5v M g7f)aApply the effect and/or codecs to the given tensor chunk by chunk. Args: waveform (Tensor): The input waveform. Shape: ``(time, channel)`` sample_rate (int): Sample rate of the waveform. frames_per_chunk (int): The number of frames to return at a time. output_sample_rate (int or None, optional): Output sample rate. If provided, override the output sample rate. Otherwise, the resulting tensor is resampled to have the same sample rate as the input. Default: ``None``. Returns: Iterator[Tensor]: Series of processed chunks. Shape: ``(time, channel)``, where the the number of frames matches ``frames_per_chunk`` except the last chunk, which could be shorter. rrrN)rr:rr}streamr)rrxrCrHryr|rs rrAudioEffector.stream>sm* ==A LX]]O\] ] >> q O!!(9K^ --/JW/ !*sA8A:)rGrDrFrKro)NNr)r"r#r$r%r&rr`r boolrr}rr_rrrr(r)rrrmrmsnd!% $ "&.2   #  {+ $@f3HUXMek:nr""-0"DG"]efi]j" & ""rrm)rbtypingrrrr4r!torio.io._streaming_media_decoderrrrw!torio.io._streaming_media_encoderr r rPr r*r>r@r_r`rerkrmr)rrrs ++ f`, 5;; ("("V     c]  ;' 0 ekk \"\"r