async def g(): uapi = UAPI(request, DictObject(**globals())) async for c in uapi('kyrag', 'jump-in', user): yield c return await stream_response(request, g)