callback-executor 0.0.1

A callback queue that execute each callback in a minimum period of time.

Request Sender

This module provides a CallbackExecutor class to receive and queue callbacks to be executed in a defined minimum interval.

Use Case

If one needs to limit the rate of request to an API endpoint.

Sample Code

import asyncio
from callback_executor import ExecutorQueue

async main():
    exec_queue = ExecutorQueue(call_interval=0.5)
    await exec_queue.ready()
    
    tasks = [
        exec_queue.enqueue_callback(blocking_request_to_api_1),
        exec_queue.enqueue_callback(blocking_request_to_api_2),
    ]
    
    responses = await asyncio.gather(*tasks)
    
    # Handle responses

if __name__ == "__main__":
    asyncio.run(main())