Added rate limiting

web-atoms · Oct 5, 2023 · f648e00 · f648e00
1 parent c058fb1
commit f648e00
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/models/Queue.ts b/src/models/Queue.ts
@@ -46,14 +46,16 @@ export default class Queue<T> {
     }
 
     private resize(n: number) {
-        const old = this.store;
-        this.store = new Array(n);
         if (!this.length) {
+            // this will clear all existing items...
+            this.store.length = 0;
+            this.store.length = n;
             this.start = 0;
             return;
         }
         if (this.start > 0) {
-
+            const old = this.store;
+            this.store = new Array(n);
             const afterStart = Math.min(
                 this.start + this.length,
                 old.length - this.start
@@ -73,9 +75,7 @@ export default class Queue<T> {
             this.start = 0;
             return;
         }
-        if (this.length > 0) {
-            this.store.push(... old);
-        }
+        this.store.length = n;
     }
 
 }
diff --git a/src/models/TaskManager.ts b/src/models/TaskManager.ts
@@ -41,12 +41,12 @@ export default class TaskManager {
             fx().then(
                 (r) => {
                     this.running.delete(fx);
-                    setTimeout(this.processQueue, 1, this);
+                    setTimeout(() => this.processQueue(), 1);
                     resolve(r);
                 },
                 (e) => {
                     this.running.delete(fx);
-                    setTimeout(this.processQueue, 1, this);
+                    setTimeout(() => this.processQueue(), 1);
                     reject(e);
                 }
             );