@staticmethod
async def tts_node(
...
# ask-aia
able-jackal-84140
07/14/2025, 5:59 AM@staticmethod
async def tts_node(
agent: Agent, text: AsyncIterable[str], model_settings: ModelSettings
) -> AsyncGenerator[rtc.AudioFrame, None]:
"""Default implementation for `Agent.tts_node`"""
activity = agent._get_activity_or_raise()
assert activity.tts is not None, "tts_node called but no TTS node is available"
wrapped_tts = activity.tts
if not activity.tts.capabilities.streaming:
wrapped_tts = tts.StreamAdapter(
tts=wrapped_tts, sentence_tokenizer=tokenize.basic.SentenceTokenizer(min_sentence_len=5, stream_context_len=5)
)
conn_options = activity.session.conn_options.tts_conn_options
async with wrapped_tts.stream(conn_options=conn_options) as stream:
async def _forward_input() -> None:
async for chunk in text:
logger.info(f"This is chunk {chunk}")
stream.push_text(chunk)
stream.end_input()
forward_task = asyncio.create_task(_forward_input())
try:
async for ev in stream:
yield ev.frame
finally:
await utils.aio.cancel_and_wait(forward_task)
In here I have already received the partial chunk to be sent. But its not sending, does it wait for the next left chunk to be sent.
t
tall-airline-16756
07/14/2025, 5:59 AMThanks for reaching out, Aditya. I'm an AI assistant and I'm here to help. Give me a moment while I research this topic.
tall-airline-16756
07/14/2025, 6:00 AMWhen you call
stream.push_text(chunk)async for chunk in textpush_textflush()push_texttts_nodepush_text2 Views