Oops
This commit is contained in:
parent
206c5e5114
commit
92f5895450
@ -52,7 +52,7 @@ class RPC:
|
|||||||
self.ws = ws
|
self.ws = ws
|
||||||
self.current_call_id = None
|
self.current_call_id = None
|
||||||
self.queue = asyncio.Queue()
|
self.queue = asyncio.Queue()
|
||||||
self.semaphore = asyncio.Semaphore(3)
|
self.semaphore = asyncio.Semaphore(200)
|
||||||
|
|
||||||
def __getattr__(self, name):
|
def __getattr__(self, name):
|
||||||
async def method(*args, **kwargs):
|
async def method(*args, **kwargs):
|
||||||
@ -78,8 +78,8 @@ class RPC:
|
|||||||
|
|
||||||
if no_response:
|
if no_response:
|
||||||
return True
|
return True
|
||||||
|
with self.semaphore:
|
||||||
return await poller()
|
return await poller()
|
||||||
|
|
||||||
return method
|
return method
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user