Compare commits
No commits in common. "e21c6a0aac6783181c9331dd0ebc39ae9fb3c40a" and "b30c70765a1559bba1518d84537b2e69ff5d4f3d" have entirely different histories.
e21c6a0aac
...
b30c70765a
@ -67,10 +67,7 @@ class UAPI:
|
|||||||
raise e
|
raise e
|
||||||
return None, None
|
return None, None
|
||||||
apiset = apisets[0]
|
apiset = apisets[0]
|
||||||
recs = await sor.R('uapi', {
|
r recs = await sor.R('uapi', {'name':apiname, 'apisetid': upapp.apisetid})
|
||||||
'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]
|
||||||
@ -100,8 +97,8 @@ class UAPI:
|
|||||||
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 def stream_linify(self, upappid, apiname, callerid, params={}):
|
async 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
|
||||||
@ -175,5 +172,3 @@ where a.id = b.upappid
|
|||||||
'myappid': r.myappid
|
'myappid': r.myappid
|
||||||
})
|
})
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
print('test')
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user