examples: remove "on_client_closed"

This has been replaced for "on_client_disconnected" in SmallWebRTCTransport to
match other transports and therefore it is not necessary anymore.

examples/foundational/03-still-frame.py

@@ -62,11 +62,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/03b-still-frame-imagen.py

@@ -62,11 +62,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/04-transports-small-webrtc.py

@@ -112,11 +112,6 @@ async def run_example(webrtc_connection: SmallWebRTCConnection):
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=False)
 
     await runner.run(task)

examples/foundational/05-sync-speech-and-image.py

@@ -168,11 +168,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         # Run the pipeline
         runner = PipelineRunner(handle_sigint=handle_sigint)
         await runner.run(task)

examples/foundational/06-listen-and-respond.py

@@ -132,11 +132,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)
 

examples/foundational/06a-image-sync.py

@@ -151,11 +151,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)
 

examples/foundational/07-interruptible-cartesia-http.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07-interruptible.py

@@ -102,11 +102,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07b-interruptible-langchain.py

@@ -135,11 +135,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07c-interruptible-deepgram-vad.py

@@ -114,11 +114,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07c-interruptible-deepgram.py

@@ -100,11 +100,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07d-interruptible-elevenlabs-http.py

@@ -107,11 +107,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/07d-interruptible-elevenlabs.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07e-interruptible-playht-http.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07e-interruptible-playht.py

@@ -105,11 +105,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07f-interruptible-azure.py

@@ -109,11 +109,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07g-interruptible-openai.py

@@ -104,11 +104,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07h-interruptible-openpipe.py

@@ -108,11 +108,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07i-interruptible-xtts.py

@@ -106,11 +106,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/07j-interruptible-gladia.py

@@ -111,11 +111,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)
 

examples/foundational/07k-interruptible-lmnt.py

@@ -99,11 +99,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07l-interruptible-groq.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07m-interruptible-aws.py

@@ -106,11 +106,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07n-interruptible-google.py

@@ -107,11 +107,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07o-interruptible-assemblyai.py

@@ -105,11 +105,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07p-interruptible-krisp.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07q-interruptible-rime-http.py

@@ -108,11 +108,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/07q-interruptible-rime.py

@@ -102,11 +102,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07r-interruptible-riva-nim.py

@@ -99,11 +99,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07s-interruptible-google-audio-in.py

@@ -276,11 +276,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07t-interruptible-fish.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07u-interruptible-ultravox.py

@@ -91,11 +91,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07v-interruptible-neuphonic-http.py

@@ -103,11 +103,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07v-interruptible-neuphonic.py

@@ -102,11 +102,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07w-interruptible-fal.py

@@ -105,11 +105,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/07y-interruptible-minimax.py

@@ -109,11 +109,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/07z-interruptible-sarvam.py

@@ -108,11 +108,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/09-mirror.py

@@ -90,11 +90,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/09a-local-mirror.py

@@ -113,11 +113,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await asyncio.gather(runner.run(task), run_tk())

examples/foundational/10-wake-phrase.py

@@ -98,11 +98,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/11-sound-effects.py

@@ -156,11 +156,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/12-describe-video.py

@@ -119,11 +119,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/12a-describe-video-gemini-flash.py

@@ -122,11 +122,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/12b-describe-video-gpt-4o.py

@@ -122,11 +122,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/12c-describe-video-anthropic.py

@@ -122,11 +122,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13-whisper-transcription.py

@@ -66,11 +66,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13b-deepgram-transcription.py

@@ -60,11 +60,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13c-gladia-transcription.py

@@ -60,11 +60,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13c-gladia-translation.py

@@ -81,11 +81,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13d-assemblyai-transcription.py

@@ -59,11 +59,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/13e-whisper-mlx.py

@@ -93,11 +93,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14-function-calling.py

@@ -133,11 +133,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14a-function-calling-anthropic.py

@@ -126,11 +126,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14b-function-calling-anthropic-video.py

@@ -194,11 +194,6 @@ If you need to use a tool, simply use the tool. Do not tell the user the tool yo
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14c-function-calling-together.py

@@ -126,11 +126,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14d-function-calling-video.py

@@ -177,11 +177,6 @@ indicate you should use the get_image tool are:
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14e-function-calling-gemini.py

@@ -187,11 +187,6 @@ indicate you should use the get_image tool are:
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14f-function-calling-groq.py

@@ -135,11 +135,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14g-function-calling-grok.py

@@ -128,11 +128,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14h-function-calling-azure.py

@@ -134,11 +134,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14i-function-calling-fireworks.py

@@ -133,11 +133,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14j-function-calling-nim.py

@@ -131,11 +131,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14k-function-calling-cerebras.py

@@ -141,11 +141,6 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14l-function-calling-deepseek.py

@@ -141,11 +141,6 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14m-function-calling-openrouter.py

@@ -135,11 +135,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14n-function-calling-perplexity.py

@@ -108,11 +108,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14o-function-calling-gemini-openai-format.py

@@ -130,11 +130,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14p-function-calling-gemini-vertex-ai.py

@@ -67,10 +67,10 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
     )
 
     llm = GoogleVertexLLMService(
-        # credentials="<json-credentials>",
+        credentials=os.getenv("GOOGLE_TEST_CREDENTIALS"),
         params=GoogleVertexLLMService.InputParams(
             project_id="<google-project-id>",
-        )
+        ),
     )
     # You can aslo register a function_name of None to get all functions
     # sent to the same callback with an additional function_name parameter.
@@ -136,11 +136,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14q-function-calling-qwen.py

@@ -133,11 +133,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/14r-function-calling-aws.py

@@ -137,11 +137,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/15-switch-voices.py

@@ -166,11 +166,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/15a-switch-languages.py

@@ -154,11 +154,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/16-gpu-container-local-bot.py

@@ -137,11 +137,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/17-detect-user-idle.py

@@ -135,11 +135,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/19-openai-realtime-beta.py

@@ -177,11 +177,6 @@ Remember, your responses should be short. Just one or two sentences, usually."""
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/19a-azure-realtime-beta.py

@@ -176,11 +176,6 @@ Remember, your responses should be short. Just one or two sentences, usually."""
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/20a-persistent-context-openai.py

@@ -241,11 +241,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/20b-persistent-context-openai-realtime.py

@@ -251,11 +251,6 @@ Remember, your responses should be short. Just one or two sentences, usually."""
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/20c-persistent-context-anthropic.py

@@ -240,11 +240,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/20d-persistent-context-gemini.py

@@ -299,11 +299,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/20e-persistent-context-aws-nova-sonic.py

@@ -264,11 +264,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/21a-tavus-video-service.py

@@ -120,11 +120,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
             logger.info(f"Client disconnected")
             await task.cancel()
 
-        @transport.event_handler("on_client_closed")
-        async def on_client_closed(transport, client):
-            logger.info(f"Client closed connection")
-            await task.cancel()
-
         runner = PipelineRunner(handle_sigint=handle_sigint)
 
         await runner.run(task)

examples/foundational/22-natural-conversation.py

@@ -166,11 +166,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/22b-natural-conversation-proposal.py

@@ -391,11 +391,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/22c-natural-conversation-mixed-llms.py

@@ -598,11 +598,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/22d-natural-conversation-gemini-audio.py

@@ -777,11 +777,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/23-bot-background-sound.py

@@ -132,11 +132,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/24-stt-mute-filter.py

@@ -140,11 +140,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/25-google-audio-in.py

@@ -374,11 +374,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/26-gemini-multimodal-live.py

@@ -113,11 +113,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     # Run the pipeline
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)

examples/foundational/26a-gemini-multimodal-live-transcription.py

@@ -124,11 +124,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     # Register event handler for transcript updates
     @transcript.event_handler("on_transcript_update")
     async def on_transcript_update(processor, frame):

examples/foundational/26b-gemini-multimodal-live-function-calling.py

@@ -149,11 +149,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/26c-gemini-multimodal-live-video.py

@@ -10,7 +10,7 @@ import os
 
 from dotenv import load_dotenv
 from loguru import logger
-from run import get_transport_client_id, maybe_capture_participant_video
+from run import maybe_capture_participant_video
 
 from pipecat.audio.vad.silero import SileroVADAnalyzer
 from pipecat.audio.vad.vad_analyzer import VADParams
@@ -105,11 +105,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/26d-gemini-multimodal-live-text.py

@@ -136,11 +136,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/26e-gemini-multimodal-google-search.py

@@ -120,11 +120,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/27-simli-layer.py

@@ -108,11 +108,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)
 

examples/foundational/28-transcription-processor.py

@@ -170,11 +170,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)
 

examples/foundational/29-turn-tracking-observer.py

@@ -118,11 +118,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/30-observer.py

@@ -163,11 +163,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
 
     await runner.run(task)

examples/foundational/32-gemini-grounding-metadata.py

@@ -145,11 +145,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
         logger.info(f"Client disconnected")
         await task.cancel()
 
-    @transport.event_handler("on_client_closed")
-    async def on_client_closed(transport, client):
-        logger.info(f"Client closed connection")
-        await task.cancel()
-
     runner = PipelineRunner(handle_sigint=handle_sigint)
     await runner.run(task)