highperfocused/lnbits
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits.git synced 2025-06-27 09:11:57 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: await

Browse Source
This commit is contained in:
Vlad Stan 2024-06-25 19:46:23 +03:00
parent 9a84dd940f
commit 2fd2dde242
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lnbits/utils/gateway.py
View File

@ -230,7 +230,7 @@ class HTTPTunnelClient:
if request_id: if request_id:
await self._handle_request_id(resp, request_id) await self._handle_request_id(resp, request_id)
else: else:
self._handle_streaming(resp) await self._handle_streaming(resp)
async def _handle_request_id(self, resp, request_id): async def _handle_request_id(self, resp, request_id):
awaiting_req = self._req_resp.get(request_id) awaiting_req = self._req_resp.get(request_id)
@ -239,9 +239,9 @@ class HTTPTunnelClient:
else: else:
logger.warning(f"Unknown request id: '{request_id}'. Possible timeout!") logger.warning(f"Unknown request id: '{request_id}'. Possible timeout!")
def _handle_streaming(self, data: dict): async def _handle_streaming(self, data: dict):
print("### handle streaming here", data) print("### handle streaming here", data)
self._chunks.put(data) await self._chunks.put(data)
class HTTPTunnelResponse: class HTTPTunnelResponse: