1. class RequestThrottler {
  2. constructor(maxRequestsPerInterval, intervalMs) {
  3. this.maxRequestsPerInterval = maxRequestsPerInterval;
  4. this.intervalMs = intervalMs;
  5. this.requests = [];
  6. this.nextRun = Date.now() + intervalMs;
  7. }
  9. /**
  10. * Schedules a request to be made.
  11. * @param {function} requestFunc - The function to execute for the request. Should return a Promise.
  12. * @returns {Promise} - A promise that resolves when the request is completed.
  13. */
  14. scheduleRequest(requestFunc) {
  15. return new Promise((resolve, reject) => {
  16. this.requests.push({ func: requestFunc, resolve, reject });
  17. this.processRequests();
  18. });
  19. }
  21. /**
  22. * Processes the pending requests.
  23. */
  24. processRequests() {
  25. const now = Date.now();
  26. if (now >= this.nextRun) {
  27. this.nextRun = now + this.intervalMs;
  28. while (this.requests.length > 0) {
  29. const request = this.requests.shift();
  30. try {
  31. const result = request.func();
  32. request.resolve(result);
  33. } catch (error) {
  34. request.reject(error);
  35. }
  36. }
  37. }
  38. }
  39. }
  42. // Example usage:
  43. // const throttler = new RequestThrottler(2, 1000); // Allow 2 requests per second
  45. // const request1 = () => {
  46. // return new Promise(resolve => setTimeout(() => {resolve("Response 1");}, 500));
  47. // };
  49. // const request2 = () => {
  50. // return new Promise(resolve => setTimeout(() => {resolve("Response 2");}, 800));
  51. // };
  53. // const request3 = () => {
  54. // return new Promise(resolve => setTimeout(() => {resolve("Response 3");}, 300));
  55. // };
  57. // throttler.scheduleRequest(request1)
  58. // .then(result => console.log("Request 1:", result))
  59. // .catch(error => console.error("Request 1 error:", error));
  61. // throttler.scheduleRequest(request2)
  62. // .then(result => console.log("Request 2:", result))
  63. // .catch(error => console.error("Request 2 error:", error));
  65. // throttler.scheduleRequest(request3)
  66. // .then(result => console.log("Request 3:", result))
  67. // .catch(error => console.error("Request 3 error:", error));

Add your comment