...

src/dailyai/services/ai_services.py

@@ -50,6 +50,10 @@ class PipeService(AbstractPipeService):
         self.source = source
         self.sink = sink
 
+    def chain(self, service: AbstractPipeService) -> AbstractPipeService:
+        self.source = service.sink
+        return self
+
     async def process_queue(self):
         if not self.source:
             return

src/examples/foundational/01-say-one-thing.py

@@ -35,7 +35,6 @@ async def main(room_url):
             voice_id=os.getenv("ELEVENLABS_VOICE_ID"))
         """
         tts = PlayHTAIService(
-            source=None,
             sink=transport.send_queue,
             api_key=os.getenv("PLAY_HT_API_KEY"),
             user_id=os.getenv("PLAY_HT_USER_ID"),

src/examples/foundational/02-llm-say-one-thing.py

@@ -30,12 +30,11 @@ async def main(room_url):
         )
 
         tts = ElevenLabsTTSService(
-            source=llm,
             sink=transport.send_queue,
             aiohttp_session=session,
             api_key=os.getenv("ELEVENLABS_API_KEY"),
             voice_id=os.getenv("ELEVENLABS_VOICE_ID"),
-        )
+        ).chain(llm)
 
         messages = [{
             "role": "system",