mirror of
				https://github.com/TitanEmbeds/Titan.git
				synced 2025-11-03 23:37:09 +01:00 
			
		
		
		
	Sleep after every subscribe
This commit is contained in:
		@@ -36,7 +36,6 @@ class RedisQueue:
 | 
			
		||||
        await self.bot.wait_until_ready()
 | 
			
		||||
        subscriber = await self.sub_connection.start_subscribe()
 | 
			
		||||
        await subscriber.subscribe(["discord-api-req"])
 | 
			
		||||
        count = 0
 | 
			
		||||
        while True:
 | 
			
		||||
            if not self.bot.is_ready() or self.bot.is_closed():
 | 
			
		||||
                await asyncio.sleep(1)
 | 
			
		||||
@@ -45,10 +44,6 @@ class RedisQueue:
 | 
			
		||||
            request = json.loads(reply.value)
 | 
			
		||||
            resource = request["resource"]
 | 
			
		||||
            self.dispatch(resource, request["key"], request["params"])
 | 
			
		||||
            count = count + 1
 | 
			
		||||
            if count > 10:
 | 
			
		||||
                count = 0
 | 
			
		||||
            elif count == 10:
 | 
			
		||||
            await asyncio.sleep(0)
 | 
			
		||||
    
 | 
			
		||||
    def dispatch(self, event, key, params):
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user