Rate limit python asyncio

ratelimit.py

import asyncio
import collections

async def ratelimit(*, max_request, in_interval):
    slots = collections.deque()
    while True:
        slots.append(time() + in_interval)
        yield
        while len(slots) >= max_request:
            left = slots[0] - time()
            if left <= 0:
                slots.popleft()
            else:
                await asyncio.sleep(left)

use.py

rate_limit = ratelimit(max_request=5, in_interval=10)

async def ratelimit_controlled_function():
    await rate_limit.__anext__()
    do_whatever()
    
    
async def a_lot_of_functions_to_run():
    async for _ in rate_limit:
        await function()