async def aget_completion_stream(self, messages, system_prompt=None):
        """Return an async iterator with response chunks."""
        for chunk in self.response_chunks:
            yield {"choices": [{"delta": {"content": chunk}}]}
Return an async iterator with response chunks.
py/tests/unit/agent/test_streaming_agent.py