This commit is contained in:
retoor 2025-09-07 04:28:12 +02:00
parent 92f5895450
commit 7abf9d1d90

View File

@ -52,7 +52,7 @@ class RPC:
self.ws = ws
self.current_call_id = None
self.queue = asyncio.Queue()
self.semaphore = asyncio.Semaphore(200)
self.semaphore = asyncio.Semaphore(1)
def __getattr__(self, name):
async def method(*args, **kwargs):
@ -78,7 +78,7 @@ class RPC:
if no_response:
return True
with self.semaphore:
async with self.semaphore:
return await poller()
return method