This commit is contained in:
yumoqing 2025-08-06 14:39:35 +08:00
parent bbe8ac33fb
commit e21c6a0aac

View File

@ -67,7 +67,10 @@ class UAPI:
raise e raise e
return None, None return None, None
apiset = apisets[0] apiset = apisets[0]
r recs = await sor.R('uapi', {'name':apiname, 'apisetid': upapp.apisetid}) recs = await sor.R('uapi', {
'name':apiname,
'apisetid': upapp.apisetid
})
if len(recs)==0: if len(recs)==0:
return None, None return None, None
uapi = recs[0] uapi = recs[0]
@ -97,8 +100,8 @@ r recs = await sor.R('uapi', {'name':apiname, 'apisetid': upapp.apisetid})
await self.do_auth(auth_uapi) await self.do_auth(auth_uapi)
async for chunk in self.stream_resp(uapi): async for chunk in self.stream_resp(uapi):
yield chunk yield chunk
t
async stream_linify(self, upappid, apiname, callerid, params={}): async def stream_linify(self, upappid, apiname, callerid, params={}):
gen = liner(self.__call__(upappid, apiname, callerid, params=params)) gen = liner(self.__call__(upappid, apiname, callerid, params=params))
async for line in gen: async for line in gen:
yield line yield line