wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Renaming insert_silence to auto_silence

Browse Source
This commit is contained in:
filipi87
2026-03-23 18:12:26 -03:00
parent ddd1b71b56
commit 066b206b3d
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/pipecat/transports/smallwebrtc/transport.py
View File

@@ -79,17 +79,17 @@ class RawAudioTrack(AudioStreamTrack):
supporting queued audio data with proper synchronization. supporting queued audio data with proper synchronization.
""" """
def __init__(self, sample_rate: int, insert_silence: bool = True): def __init__(self, sample_rate: int, auto_silence: bool = True):
"""Initialize the raw audio track. """Initialize the raw audio track.
Args: Args:
sample_rate: The audio sample rate in Hz. sample_rate: The audio sample rate in Hz.
insert_silence: If True, emit silence when the queue is empty. If False, auto_silence: If True, emit silence when the queue is empty. If False,
wait until audio data is available. wait until audio data is available.
""" """
super().__init__() super().__init__()
self._sample_rate = sample_rate self._sample_rate = sample_rate
self._insert_silence = insert_silence self._auto_silence = auto_silence
self._samples_per_10ms = sample_rate * 10 // 1000 self._samples_per_10ms = sample_rate * 10 // 1000
self._bytes_per_10ms = self._samples_per_10ms * 2 # 16-bit (2 bytes per sample) self._bytes_per_10ms = self._samples_per_10ms * 2 # 16-bit (2 bytes per sample)
self._timestamp = 0 self._timestamp = 0
@@ -127,7 +127,7 @@ class RawAudioTrack(AudioStreamTrack):
Returns: Returns:
An AudioFrame containing the next audio data, or silence if the queue is empty An AudioFrame containing the next audio data, or silence if the queue is empty
and ``insert_silence`` is True. and ``auto_silence`` is True.
""" """
# Compute required wait time for synchronization # Compute required wait time for synchronization
if self._timestamp > 0: if self._timestamp > 0:
@@ -136,7 +136,7 @@ class RawAudioTrack(AudioStreamTrack):
await asyncio.sleep(wait) await asyncio.sleep(wait)
if not self._chunk_queue: if not self._chunk_queue:
if self._insert_silence: if self._auto_silence:
chunk = bytes(self._bytes_per_10ms) chunk = bytes(self._bytes_per_10ms)
else: else:
while not self._chunk_queue: while not self._chunk_queue:
@@ -497,7 +497,7 @@ class SmallWebRTCClient:
if self._params.audio_out_enabled: if self._params.audio_out_enabled:
self._audio_output_track = RawAudioTrack( self._audio_output_track = RawAudioTrack(
sample_rate=self._out_sample_rate, sample_rate=self._out_sample_rate,
insert_silence=self._params.audio_out_auto_silence, auto_silence=self._params.audio_out_auto_silence,
) )
self._webrtc_connection.replace_audio_track(self._audio_output_track) self._webrtc_connection.replace_audio_track(self._audio_output_track)