From 27dbfa1eda7b7e7e74ba8b68a8013752d6d98c39 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 28 Jan 2026 22:34:26 -0800 Subject: [PATCH] NvidiaTTSService: return AsyncIterator instead of AsyncIterable --- src/pipecat/services/nvidia/tts.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/pipecat/services/nvidia/tts.py b/src/pipecat/services/nvidia/tts.py index eddafce01..e90462ad9 100644 --- a/src/pipecat/services/nvidia/tts.py +++ b/src/pipecat/services/nvidia/tts.py @@ -12,7 +12,7 @@ gRPC API for high-quality speech synthesis. import asyncio import os -from typing import AsyncGenerator, AsyncIterable, Generator, Mapping, Optional +from typing import AsyncGenerator, AsyncIterator, Generator, Mapping, Optional from pipecat.utils.tracing.service_decorators import traced_tts @@ -181,7 +181,7 @@ class NvidiaTTSService(TTSService): except StopIteration: return None - async def async_iterator(iterator) -> AsyncIterable[rtts.SynthesizeSpeechResponse]: + async def async_iterator(iterator) -> AsyncIterator[rtts.SynthesizeSpeechResponse]: while True: item = await asyncio.to_thread(async_next, iterator) if item is None: