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