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

Merge pull request #1934 from counterleft/use-disconnect-on-small-webrtc-connection-example

Browse Source 
Fix type checker error with missing function call in the small WebRTC transport example
This commit is contained in:
Mark Backman
2025-06-02 11:17:30 -04:00
committed by GitHub
parent b8b1990617 2eb2c5a413
commit dac3f82a75
5 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/foundational/04-transports-small-webrtc.py
View File

@@ -156,7 +156,7 @@ async def offer(request: dict, background_tasks: BackgroundTasks):
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
yield # Run app yield # Run app
coros = [pc.close() for pc in pcs_map.values()] coros = [pc.disconnect() for pc in pcs_map.values()]
await asyncio.gather(*coros) await asyncio.gather(*coros)
pcs_map.clear() pcs_map.clear()

2
examples/p2p-webrtc/daily-interop-bridge/server.py
View File

@@ -74,7 +74,7 @@ async def offer(request: dict, background_tasks: BackgroundTasks):
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
yield # Run app yield # Run app
coros = [pc.close() for pc in pcs_map.values()] coros = [pc.disconnect() for pc in pcs_map.values()]
await asyncio.gather(*coros) await asyncio.gather(*coros)
pcs_map.clear() pcs_map.clear()

2
examples/p2p-webrtc/video-transform/server/server.py
View File

@@ -74,7 +74,7 @@ async def offer(request: dict, background_tasks: BackgroundTasks):
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
yield # Run app yield # Run app
coros = [pc.close() for pc in pcs_map.values()] coros = [pc.disconnect() for pc in pcs_map.values()]
await asyncio.gather(*coros) await asyncio.gather(*coros)
pcs_map.clear() pcs_map.clear()

2
examples/p2p-webrtc/voice-agent/server.py
View File

@@ -69,7 +69,7 @@ async def serve_index():
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
yield # Run app yield # Run app
coros = [pc.close() for pc in pcs_map.values()] coros = [pc.disconnect() for pc in pcs_map.values()]
await asyncio.gather(*coros) await asyncio.gather(*coros)
pcs_map.clear() pcs_map.clear()

2
src/pipecat/examples/run.py
View File

@@ -142,7 +142,7 @@ def run_example_webrtc(
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
yield # Run app yield # Run app
coros = [pc.close() for pc in pcs_map.values()] coros = [pc.disconnect() for pc in pcs_map.values()]
await asyncio.gather(*coros) await asyncio.gather(*coros)
pcs_map.clear() pcs_map.clear()