Function _drain_async

python/copilot/copilot_request_handler.py:690–695

(stream: AsyncIterator[bytes])

async def _drain_async(stream: AsyncIterator[bytes]) -> bytes:
    parts: list[bytes] = []
    async for chunk in stream:
        if chunk:
            parts.append(chunk)
    return b"".join(parts)


async def _stream_response_to_exchange(