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

remove _internal_push_frame from LiveKitInputTransport

Browse Source
This commit is contained in:
joachimchauvet
2024-09-24 14:54:37 +03:00
parent b6e1d6e6ae
commit ec5998bc36
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/transports/services/livekit.py
View File

@@ -326,7 +326,7 @@ class LiveKitInputTransport(BaseInputTransport):
async def push_app_message(self, message: Any, sender: str): async def push_app_message(self, message: Any, sender: str):
frame = LiveKitTransportMessageFrame(message=message, participant_id=sender) frame = LiveKitTransportMessageFrame(message=message, participant_id=sender)
await self._internal_push_frame(frame) await self.push_frame(frame)
async def _audio_in_task_handler(self): async def _audio_in_task_handler(self):
logger.info("Audio input task started") logger.info("Audio input task started")
@@ -337,7 +337,7 @@ class LiveKitInputTransport(BaseInputTransport):
audio_frame_event, participant_id = audio_data audio_frame_event, participant_id = audio_data
pipecat_audio_frame = self._convert_livekit_audio_to_pipecat(audio_frame_event) pipecat_audio_frame = self._convert_livekit_audio_to_pipecat(audio_frame_event)
await self.push_audio_frame(pipecat_audio_frame) await self.push_audio_frame(pipecat_audio_frame)
await self._internal_push_frame( await self.push_frame(
pipecat_audio_frame pipecat_audio_frame
) # TODO: ensure audio frames are pushed with the default BaseInputTransport.push_audio_frame() ) # TODO: ensure audio frames are pushed with the default BaseInputTransport.push_audio_frame()
except asyncio.CancelledError: except asyncio.CancelledError: