yumoqing/uapi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-08-07 18:19:29 +08:00
parent 5470d3be33
commit 096c35332a
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
uapi/appapi.py
View File

@ -117,7 +117,15 @@ class UAPI:
async def 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 filter = self.api.chunk_match
if line.startswith(filter):
line = line[len(filter):]
if self.api.streamresponse:
dic = json.loads(line)
line = self.rendertmpl(self.api.streamresponse, dic)
yield line
else:
debug(f'invalid line:{line}')
async def request(self, upappid, apiname, callerid, params={}): async def request(self, upappid, apiname, callerid, params={}):
b = b'' b = b''