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

Merge pull request #604 from natestraub/patch-1

Browse Source 
services(livekit) - Stop Sending EndFrame when Participant Disconnects
This commit is contained in:
Aleix Conchillo Flaqué
2024-10-17 08:48:57 -07:00
committed by GitHub
parent e31d1152db d4ec6827ce
commit 197d7b3e2b
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -556,10 +556,6 @@ class LiveKitTransport(BaseTransport):
async def _on_participant_disconnected(self, participant_id: str): async def _on_participant_disconnected(self, participant_id: str):
await self._call_event_handler("on_participant_disconnected", participant_id) await self._call_event_handler("on_participant_disconnected", participant_id)
await self._call_event_handler("on_participant_left", participant_id, "disconnected") await self._call_event_handler("on_participant_left", participant_id, "disconnected")
if self._input:
await self._input.process_frame(EndFrame(), FrameDirection.DOWNSTREAM)
if self._output:
await self._output.process_frame(EndFrame(), FrameDirection.DOWNSTREAM)
async def _on_audio_track_subscribed(self, participant_id: str): async def _on_audio_track_subscribed(self, participant_id: str):
await self._call_event_handler("on_audio_track_subscribed", participant_id) await self._call_event_handler("on_audio_track_subscribed", participant_id)