Function consumer

tests/tools/test_execution.py:739–741

()

    results = []

    async def consumer():
        async for result in stream_execute_tools(manager, calls, batch_timeout=100.0):
            results.append(result)

    task = asyncio.create_task(consumer())
    # Give the generator time to start and block on queue.get()