Python streaming

import asyncio
from tazo import AsyncTazo, wav_chunks

async def stream_audio():
    async with AsyncTazo() as client:
        async with client.decisions.stream(
            state="Choose an action.",
            questions={"action": {
                "type": "choice",
                "instructions": "Which action should be taken?",
                "criteria": {"get_weather": "Get weather.", "NO_TOOL": "No tool needed."},
            }},
        ) as session:
            print(session.ready.max_turn_audio_ms)

            async def send():
                for chunk in wav_chunks("request.wav"):
                    await asyncio.sleep(len(chunk) / 32000)
                    await session.send_audio(chunk)
                await session.commit()

            async def receive():
                async for event in session:
                    if event.type in {"decision.updated", "decision.finalized"}:
                        print(event.model_dump())
                    if event.type == "decision.finalized":
                        await session.finish()

            async with asyncio.TaskGroup() as group:
                group.create_task(send())
                group.create_task(receive())

asyncio.run(stream_audio())