|
|
@@ -205,7 +205,7 @@ async def read(peer, size):
|
|
|
|
|
|
async def cooldown(peer, out=True):
|
|
|
if out:
|
|
|
- await asyncio.sleep(RATELIMIT)
|
|
|
+ await asyncio.sleep(RATELIMIT + 0.01)
|
|
|
else:
|
|
|
if time.time() - peer.last_message_in_ts < RATELIMIT:
|
|
|
raise Error(f'rate limit (={RATELIMIT}s.) exceeded for incoming messages')
|
