Method run

backend/python/vllm/test.py:320–321

()

    def _collect(servicer, req):
        import asyncio
        async def run():
            return [r async for r in servicer._predict(req, None, streaming=True)]
        return asyncio.run(run())

    def _new_servicer(self):