(servicer, req)
| 316 | |
| 317 | @staticmethod |
| 318 | def _collect(servicer, req): |
| 319 | import asyncio |
| 320 | async def run(): |
| 321 | return [r async for r in servicer._predict(req, None, streaming=True)] |
| 322 | return asyncio.run(run()) |
| 323 | |
| 324 | def _new_servicer(self): |
| 325 | import sys, os |
no test coverage detected