async def METHOD_NAME(flow_cls, use_stream):
    with flow_cls(asyncio=True).add(uses=MyExec) as f:
        async for r in f.post('/hello', parameters={'hello': 'world'}, stream=use_stream):
            assert isinstance(r, DocumentArray)