python/extensions/response_stream/_30_api_stream.py

async def response_stream(agent, text, parsed, **kwargs):
    if hasattr(agent.context, 'stream_queue'):
        agent.context.stream_queue.put({'type': 'response', 'text': text, 'parsed': parsed})