Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions src/pipecat/transports/smallwebrtc/transport.py
Original file line number Diff line number Diff line change
Expand Up @@ -332,6 +332,7 @@ async def read_video_frame(self, video_source: str):
format="RGB",
)
image_frame.transport_source = video_source
image_frame.pts = frame.pts

del frame # free original VideoFrame
del image_bytes # reference kept in image_frame
Expand Down Expand Up @@ -379,6 +380,7 @@ async def read_audio_frame(self):
sample_rate=resampled_frame.sample_rate,
num_channels=self._audio_in_channels,
)
audio_frame.pts = frame.pts
del pcm_bytes # reference kept in audio_frame

yield audio_frame
Expand All @@ -393,6 +395,7 @@ async def read_audio_frame(self):
sample_rate=frame.sample_rate,
num_channels=self._audio_in_channels,
)
audio_frame.pts = frame.pts
del pcm_bytes # reference kept in audio_frame

yield audio_frame
Expand Down